Skip to content
Snippets Groups Projects

Fix for incorrect name extraction in the MCO delivery event

Merged Adham Hashibon requested to merge fix-incorrect-name-extraction into master
1 file
+ 6
6
Compare changes
  • Side-by-side
  • Inline
@@ -55,17 +55,17 @@ class CoreMCODriver(BaseCoreDriver):
@@ -55,17 +55,17 @@ class CoreMCODriver(BaseCoreDriver):
@on_trait_change("mco:started")
@on_trait_change("mco:started")
def _deliver_start_event(self):
def _deliver_start_event(self):
output_names = []
output_kpis = []
for layer in self.workflow.execution_layers:
for layer in self.workflow.execution_layers:
for data_source in layer.data_sources:
for data_source in layer.data_sources:
output_names.extend(info.name
output_kpis.extend(
for info in data_source.output_slot_info
info for info in data_source.output_slot_info
if info.is_kpi
if info.is_kpi
)
)
self._deliver_event(MCOStartEvent(
self._deliver_event(MCOStartEvent(
input_names=tuple(p.name for p in self.workflow.mco.parameters),
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")
@on_trait_change("mco:finished")
Loading