diff --git a/distributed/rpc/rl/main.py b/distributed/rpc/rl/main.py index 91451ecc84..50a9bcdda5 100644 --- a/distributed/rpc/rl/main.py +++ b/distributed/rpc/rl/main.py @@ -164,7 +164,7 @@ def run_episode(self, n_steps=0): ) ) - # wait until all obervers have finished this episode + # wait until all observers have finished this episode for fut in futs: fut.wait()