fix setting up gearman order

This commit is contained in:
Joshua Hesketh 2013-08-13 12:39:35 +10:00
parent 9160757353
commit 4962ce9e59
1 changed files with 3 additions and 2 deletions

View File

@ -46,9 +46,8 @@ class Runner(threading.Thread):
# Set up the runner worker
self.gearman_worker = None
self.setup_gearman()
self.datasets = []
self.job = None
self.job_arguments = None
self.job_datasets = []
@ -59,6 +58,8 @@ class Runner(threading.Thread):
self.current_step = 0
self.total_steps = 4
self.setup_gearman()
def setup_gearman(self):
self.log.debug("Set up real_db gearman worker")
self.gearman_worker = gear.Worker(__worker_name__)