lib/dynflow/executors/parallel.rb in dynflow-0.8.30 vs lib/dynflow/executors/parallel.rb in dynflow-0.8.31
- old
+ new
@@ -33,9 +33,13 @@
def terminate(future = Concurrent.future)
@core.tell([:start_termination, future])
future
end
+ def execution_status(execution_plan_id = nil)
+ @core.ask!([:execution_status, execution_plan_id])
+ end
+
def initialized
@core_initialized
end
end
end