running with reddit 6

eval/step_configs/config_reddit_sharing_local.ini

@@ -24,11 +24,14 @@ loss_package = torch.nn
 loss_class = CrossEntropyLoss
 
 [COMMUNICATION]
-comm_package = decentralizepy.communication.TCPRandomWalkRouting
-comm_class = TCPRandomWalkRouting
+comm_package = decentralizepy.communication.TCPRandomWalk
+comm_class = TCPRandomWalk
 addresses_filepath = ip_addr_6Machines.json
 sampler = equi
 
 [SHARING]
-sharing_package = decentralizepy.sharing.SharingDynamicGraph
-sharing_class = SharingDynamicGraph
\ No newline at end of file
+sharing_package = decentralizepy.sharing.TopKDPSGDRW
+sharing_class = TopKDPSGDRW
+alpha = 1.0
+accumulation = True
+accumulate_averaging_changes = True
\ No newline at end of file

src/decentralizepy/node/Node.py

@@ -512,7 +512,7 @@ class Node:
         logging.info("disconnect neighbors")
         self.communication.disconnect_neighbors()
         logging.info("Storing final weight")
-        self.model.dump_weights(self.weights_store_dir, self.uid, iteration)
+        # self.model.dump_weights(self.weights_store_dir, self.uid, iteration)
         logging.info("All neighbors disconnected. Process complete!")
 
     def __init__(