diff options
Diffstat (limited to 'gear/__init__.py')
-rw-r--r-- | gear/__init__.py | 6 |
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. |