summaryrefslogtreecommitdiff
path: root/gear/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'gear/__init__.py')
-rw-r--r--gear/__init__.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/gear/__init__.py b/gear/__init__.py
index b085c29..4ed674e 100644
--- a/gear/__init__.py
+++ b/gear/__init__.py
@@ -1897,6 +1897,12 @@ class Worker(BaseClient):
else:
self._sendCanDo(name)
+ connections = self.active_connections[:]
+ for connection in connections:
+ if connection.state == "SLEEP":
+ connection.changeState("IDLE")
+ self._updateStateMachines()
+
def unRegisterFunction(self, name):
"""Remove a function from Gearman's registry.