Skip to content
Snippets Groups Projects
Unverified Commit 75cc22f6 authored by Stefano Borini's avatar Stefano Borini Committed by GitHub
Browse files

Merge pull request #124 from force-h2020/fix-incorrect-name-extraction

Fix for incorrect name extraction in the MCO delivery event
parents 5b34cff3 a3560b90
No related branches found
No related tags found
No related merge requests found
...@@ -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")
......
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