From d2dca6d966ee1107b0861808605a11cd8ef468f9 Mon Sep 17 00:00:00 2001 From: khanhkhanhlele Date: Wed, 5 Nov 2025 15:09:49 +0700 Subject: [PATCH] Fix typos in distributed/rpc/batch/reinforce.py --- distributed/rpc/batch/reinforce.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/distributed/rpc/batch/reinforce.py b/distributed/rpc/batch/reinforce.py index 0a69c8f5d1..1972107e37 100644 --- a/distributed/rpc/batch/reinforce.py +++ b/distributed/rpc/batch/reinforce.py @@ -192,7 +192,7 @@ def run_episode(self, n_steps=0): # make async RPC to kick off an episode on all observers futs.append(ob_rref.rpc_async().run_episode(self.agent_rref, n_steps)) - # wait until all obervers have finished this episode + # wait until all observers have finished this episode rets = torch.futures.wait_all(futs) rewards = torch.stack([ret[0] for ret in rets]).cuda().t() ep_rewards = sum([ret[1] for ret in rets]) / len(rets)