From a154d0471c9181a6a6461466140e881018df4b8b Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Mon, 25 Jan 2016 16:01:53 -0800
Subject: Ok to sleep in blocking poll for metadata update

---
 kafka/coordinator/base.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'kafka/coordinator/base.py')

diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index db16ca3..6efdfd0 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -205,7 +205,7 @@ class BaseCoordinator(object):
                     continue
                 elif future.retriable():
                     metadata_update = self._client.cluster.request_update()
-                    self._client.poll(future=metadata_update)
+                    self._client.poll(future=metadata_update, sleep=True)
                 else:
                     raise future.exception # pylint: disable-msg=raising-bad-type
 
-- 
cgit v1.2.1