Fix fail_hard for sync functions (#6269)

The `else` meant we would, in fact, not fail hard at all.
dask · May 13, 2022 · 4b34bd4 · 4b34bd4
1 parent bab29c5
commit 4b34bd4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -205,8 +205,7 @@ def wrapper(self, *args, **kwargs):
                         },
                     )
                     logger.exception(e)
-                else:
-                    self.loop.add_callback(_force_close, self)
+                self.loop.add_callback(_force_close, self)
 
     return wrapper