Fix fail_hard for sync functions (#6269)

gjoseph92 · web-flow · commit 4b34bd4a4fe7 · 2022-05-13T14:37:46.000-05:00
The `else` meant we would, in fact, not fail hard at all.
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
 

Original file line number	Diff line number	Diff line change
`@@ -205,8 +205,7 @@ def wrapper(self, args, *kwargs):`
`205`	`205`	`},`
`206`	`206`	`)`
`207`	`207`	`logger.exception(e)`
`208`		`- else:`
`209`		`- self.loop.add_callback(_force_close, self)`
	`208`	`+ self.loop.add_callback(_force_close, self)`
`210`	`209`
`211`	`210`	`return wrapper`
`212`	`211`