Fix manager sending job complete

This commit is contained in:
Joshua Hesketh 2013-08-12 11:17:25 +10:00
parent ef72b8a39f
commit 4a30d27ce0

View File

@ -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'))