Add missing run method to LocalWorkflow.
@@ -15,11 +15,22 @@ class LocalWorkflowProxy(WorkflowProxy):
workflow_type = "local"
+ def __init__(self, *args, **kwargs):
+ super(LocalWorkflowProxy, self).__init__(*args, **kwargs)
+
+ self._has_run = False
+
+ def complete(self):
+ return self._has_run
+
def requires(self):
reqs = super(LocalWorkflowProxy, self).requires()
reqs["branches"] = self.task.get_branch_tasks()
return reqs
+ def run(self):
+ self._has_run = True
+
class LocalWorkflow(Workflow):
