Skip to content

Commit ae40d36

Browse files
authored
add sync variable (#156)
1 parent ac47bc7 commit ae40d36

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

jorldy/manager/distributed_manager.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ def run(self, step=1):
2828
if self.mode == "sync":
2929
items = ray.get([actor.run.remote(step) for actor in self.actors])
3030
transitions = reduce(lambda x, y: x + y, [item[1] for item in items])
31+
completed_ratio = 1.0
3132
else:
3233
if len(self.running_ids) == 0:
3334
self.running_ids = [actor.run.remote(step) for actor in self.actors]

0 commit comments

Comments
 (0)