add sync variable (#156)

kakaoenterprise · Apr 1, 2022 · ae40d36 · ae40d36
1 parent ac47bc7
commit ae40d36
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/jorldy/manager/distributed_manager.py b/jorldy/manager/distributed_manager.py
@@ -28,6 +28,7 @@ def run(self, step=1):
         if self.mode == "sync":
             items = ray.get([actor.run.remote(step) for actor in self.actors])
             transitions = reduce(lambda x, y: x + y, [item[1] for item in items])
+            completed_ratio = 1.0
         else:
             if len(self.running_ids) == 0:
                 self.running_ids = [actor.run.remote(step) for actor in self.actors]