Commit c0d635ea authored by Betoule Marc's avatar Betoule Marc Committed by Betoule Marc
Browse files

add logging when worker accomplish something

parent 384c18d7
...@@ -119,10 +119,13 @@ class Worker(object): ...@@ -119,10 +119,13 @@ class Worker(object):
try: try:
for task in iter(self.scheduler.get_task, None): for task in iter(self.scheduler.get_task, None):
self.work_dir = self.pipe.get_curr_dir(task.seg) self.work_dir = self.pipe.get_curr_dir(task.seg)
self.logger.info('Processing one task of segment %s'%task.seg)
task = self.execute_task(task) task = self.execute_task(task)
if task.status == "done": if task.status == "done":
self.logger.info('task done')
self.scheduler.task_done(task) self.scheduler.task_done(task)
else: else:
self.logger.info('task failed')
self.scheduler.task_failed(task) self.scheduler.task_failed(task)
n = n+1 n = n+1
self.task = None self.task = None
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment