From dff74c7eae113a4092e13ed6d5dff5d516ad2f92 Mon Sep 17 00:00:00 2001 From: Joshua Hesketh Date: Mon, 26 Aug 2013 11:05:38 +1000 Subject: [PATCH] clear out work_data on each new job --- turbo_hipster/task_plugins/gate_real_db_upgrade/task.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py index 7d20d7a..5e96806 100644 --- a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py +++ b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py @@ -97,10 +97,12 @@ class Runner(threading.Thread): def run(self): while True and not self.stopped(): try: - # gearman_worker.getJob() blocks until a job is available - self.log.debug("Waiting for job") + # Reset job information: self.current_step = 0 self.cancelled = False + self.work_data = None + # gearman_worker.getJob() blocks until a job is available + self.log.debug("Waiting for job") self.job = self.gearman_worker.getJob() self._handle_job() except: