From b7d1dc6228f8eb49e0864ce9196b485ebfa917ea Mon Sep 17 00:00:00 2001 From: Joshua Hesketh Date: Fri, 10 Jan 2014 14:18:23 +0800 Subject: [PATCH] wait for server before registering function Change-Id: If2fd7c907c9e3bc1a2e779af9ae834d5a0d3bcc7 --- turbo_hipster/worker_manager.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/turbo_hipster/worker_manager.py b/turbo_hipster/worker_manager.py index c22d594..746e4f7 100644 --- a/turbo_hipster/worker_manager.py +++ b/turbo_hipster/worker_manager.py @@ -47,6 +47,7 @@ class ZuulManager(threading.Thread): self.config['zuul_server']['gearman_host'], self.config['zuul_server']['gearman_port'] ) + self.gearman_worker.waitForServer() self.gearman_worker.registerFunction( 'stop:turbo-hipster-manager-%s' % hostname) @@ -118,6 +119,7 @@ class ZuulClient(threading.Thread): def register_functions(self): self.log.debug("Register functions with gearman") for function_name, plugin in self.functions.items(): + self.gearman_worker.waitForServer() self.gearman_worker.registerFunction(function_name) self.log.debug(self.gearman_worker.functions)