Fixed local execution engine to actually run workers.
@@ -8,4 +8,5 @@ class LocalExecutionEngine(ExecutionEngine):
"Execution engine that runs jobs on the local machine."
def __call__(self, timeout, pending_work_items, config, on_task_complete):
for work_item in pending_work_items:
+ work_item = worker_process(work_item, timeout, config)
on_task_complete(work_item.job_id, work_item)
