From 4a30d27ce09b2085702202038ce9cfcafc184b20 Mon Sep 17 00:00:00 2001 From: Joshua Hesketh Date: Mon, 12 Aug 2013 11:17:25 +1000 Subject: [PATCH] Fix manager sending job complete --- turbo_hipster/worker_manager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/turbo_hipster/worker_manager.py b/turbo_hipster/worker_manager.py index d615f69..72034fb 100644 --- a/turbo_hipster/worker_manager.py +++ b/turbo_hipster/worker_manager.py @@ -77,6 +77,7 @@ class GearmanManager(threading.Thread): job_arguments = json.loads(job.arguments.decode('utf-8')) self.tasks[job_arguments['name']].stop_worker( job_arguments['number']) + job.sendWorkComplete() except Exception as e: self.log.exception('Exception handling log event.') job.sendWorkException(str(e).encode('utf-8'))