fix issue with scheduler namespace. Thanks @limedrop for spotting this.

This commit is contained in:
niphlod
2013-08-24 14:05:08 +02:00
parent c9aa8020a7
commit cbddfb5cdf
+2 -2
View File
@@ -238,10 +238,10 @@ def executor(queue, task, out):
result = eval(task.function)( result = eval(task.function)(
*loads(task.args, object_hook=_decode_dict), *loads(task.args, object_hook=_decode_dict),
**loads(task.vars, object_hook=_decode_dict)) **loads(task.vars, object_hook=_decode_dict))
queue.put(TaskReport(COMPLETED, result=result)) queue.put(TaskReport('COMPLETED', result=result))
except BaseException, e: except BaseException, e:
tb = traceback.format_exc() tb = traceback.format_exc()
queue.put(TaskReport(FAILED, tb=tb)) queue.put(TaskReport('FAILED', tb=tb))
del stdout del stdout