Skip to content
Snippets Groups Projects
Commit a3560b90 authored by Stefano Borini's avatar Stefano Borini
Browse files

Fix for incorrect name extraction in the MCO delivery event

parent 5b34cff3
No related branches found
No related tags found
1 merge request!124Fix for incorrect name extraction in the MCO delivery event
......@@ -55,17 +55,17 @@ class CoreMCODriver(BaseCoreDriver):
@on_trait_change("mco:started")
def _deliver_start_event(self):
output_names = []
output_kpis = []
for layer in self.workflow.execution_layers:
for data_source in layer.data_sources:
output_names.extend(info.name
for info in data_source.output_slot_info
if info.is_kpi
)
output_kpis.extend(
info for info in data_source.output_slot_info
if info.is_kpi
)
self._deliver_event(MCOStartEvent(
input_names=tuple(p.name for p in self.workflow.mco.parameters),
output_names=tuple([on.name for on in output_names])
output_names=tuple([on.name for on in output_kpis])
))
@on_trait_change("mco:finished")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment