diff --git a/src/decentralizepy/sharing/Sharing.py b/src/decentralizepy/sharing/Sharing.py index 8f8eb6a54041725e390980699d72fdb19d4550c1..ed63f8579ca61abc63eee315e915ba63b5187da8 100644 --- a/src/decentralizepy/sharing/Sharing.py +++ b/src/decentralizepy/sharing/Sharing.py @@ -124,7 +124,7 @@ class Sharing: iteration = data["iteration"] del data["degree"] del data["iteration"] - self.peer_deques[sender].append((degree, data)) + self.peer_deques[sender].append((degree, iteration, data)) logging.info( "Deserialized received model from {} of iteration {}".format( sender, iteration @@ -135,8 +135,10 @@ class Sharing: total = dict() weight_total = 0 for i, n in enumerate(self.peer_deques): - logging.debug("Averaging model from neighbor {}".format(i)) - degree, data = self.peer_deques[n].popleft() + degree, iteration, data = self.peer_deques[n].popleft() + logging.debug( + "Averaging model from neighbor {} of iteration {}".format(i, iteration) + ) data = self.deserialized_model(data) weight = 1 / (max(len(self.peer_deques), degree) + 1) # Metro-Hastings weight_total += weight