summaryrefslogtreecommitdiff
path: root/turbo_hipster/worker_manager.py
diff options
context:
space:
mode:
Diffstat (limited to 'turbo_hipster/worker_manager.py')
-rw-r--r--turbo_hipster/worker_manager.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/turbo_hipster/worker_manager.py b/turbo_hipster/worker_manager.py
index 40a1f35..a1cf47b 100644
--- a/turbo_hipster/worker_manager.py
+++ b/turbo_hipster/worker_manager.py
@@ -84,7 +84,7 @@ class ZuulManager(threading.Thread):
self.log.debug("Waiting for server")
self.gearman_worker.waitForServer()
if (not self.stopped() and self.gearman_worker.running and
- self.gearman_worker.active_connections):
+ self.gearman_worker.active_connections):
self.register_functions()
self.gearman_worker.waitForServer()
logging.debug("Waiting for job")
@@ -178,7 +178,7 @@ class ZuulClient(threading.Thread):
self.log.debug("Waiting for server")
self.gearman_worker.waitForServer()
if (not self.stopped() and self.gearman_worker.running and
- self.gearman_worker.active_connections):
+ self.gearman_worker.active_connections):
self.register_functions()
self.gearman_worker.waitForServer()
self.log.debug("Waiting for job")