Fix intermittent failure for broken_worker test
@@ -2301,7 +2301,12 @@ class Scheduler(Server):
" work stealing. Expected: %s, Got: %s, Key: %s",
w, worker, key)
msg = {'op': 'release-task', 'key': key, 'reason': 'stolen'}
+ try:
self.worker_comms[w].send(msg)
+ except CommClosedError:
+ # Don't try to resolve this now. Proceed normally and
+ # let normal resiliency mechanisms handle it later
+ logger.info("Worker comm closed unexpectedly")
recommendations = OrderedDict()
