From 1a8f8196147dcd66e745afaa235e9c028199656f Mon Sep 17 00:00:00 2001 From: brettlangdon Date: Thu, 9 Oct 2014 17:37:17 -0400 Subject: [PATCH] dont block for manager jobs --- qw/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/qw/client.py b/qw/client.py index 4302047..ecc3b90 100644 --- a/qw/client.py +++ b/qw/client.py @@ -17,7 +17,7 @@ class Client(redis.StrictRedis): def register_manager(self, name): self.sadd(self.ALL_MANAGERS, name) - def deregister_manager(self, name): + def deregister_manager(self, name) : self.srem(self.ALL_MANAGERS, name) def register_worker(self, manager, name): @@ -45,7 +45,7 @@ class Client(redis.StrictRedis): # 3) try to grab a job from the pool of all jobs job_id = ( self.lpop(self.WORKER_JOBS % (worker, )) or - self.brpoplpush(self.MANAGER_JOBS % (manager, ), self.WORKER_JOBS % (worker, ), timeout=timeout) or + self.brpoplpush(self.MANAGER_JOBS % (manager, ), self.WORKER_JOBS % (worker, )) or self.brpoplpush(self.ALL_JOBS, self.WORKER_JOBS % (worker, ), timeout=timeout) )