From 89ad616bacdfb5d348e6fdfbeda639e5c01e7831 Mon Sep 17 00:00:00 2001
From: Henrik Feldt <henrik@haf.se>
Date: Thu, 25 Nov 2021 23:25:04 +0100
Subject: [PATCH] Simple way to retry, solves #4698

---
 distributed/worker.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/distributed/worker.py b/distributed/worker.py
index 18c9d53f00f..45bc57bbfb2 100644
--- a/distributed/worker.py
+++ b/distributed/worker.py
@@ -4200,6 +4200,8 @@ async def _get_data():
             else:
                 if status == "OK":
                     await comm.write("OK")
+                elif status == "busy":
+                    raise ValueError("Retry in a little while", response)
             return response
         finally:
             rpc.reuse(worker, comm)