fix merge

dask · Jun 2, 2022 · e1058fe · e1058fe
1 parent 3e77c1b
commit e1058fe
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -2901,8 +2901,8 @@ def _handle_instructions(self, instructions: Instructions) -> None:
         for inst in instructions:
             task: asyncio.Task | None = None
 
-                if isinstance(inst, SendMessageToScheduler):
-                    self.batched_send(inst.to_dict())
+            if isinstance(inst, SendMessageToScheduler):
+                self.batched_send(inst.to_dict())
 
             elif isinstance(inst, GatherDep):
                 assert inst.to_gather