[exec] Fixed multiple event inputs

gfalcone · gfalcone · commit 25ff120e9495 · 2021-04-03T13:51:02.000+02:00
diff --git a/exec/src/klio_exec/commands/run.py b/exec/src/klio_exec/commands/run.py
@@ -485,7 +485,7 @@ def _generate_pcoll_per_input(self, pipeline):
         to_process = MultiInputPCollTuple(**input_name_to_input_pcolls)
         to_pass_thru = (
             multi_to_pass_thru
-            | "Merge multi-input pass-thrus" >> beam.Flatten()
+            | "Merge multi-input pass-thrus" >> beam.Flatten(pipeline=pipeline)
         )
         return to_process, to_pass_thru
 

Original file line number	Diff line number	Diff line change
`@@ -485,7 +485,7 @@ def _generate_pcoll_per_input(self, pipeline):`
`485`	`485`	`to_process = MultiInputPCollTuple(**input_name_to_input_pcolls)`
`486`	`486`	`to_pass_thru = (`
`487`	`487`	`multi_to_pass_thru`
`488`		`- \| "Merge multi-input pass-thrus" >> beam.Flatten()`
	`488`	`+ \| "Merge multi-input pass-thrus" >> beam.Flatten(pipeline=pipeline)`
`489`	`489`	`)`
`490`	`490`	`return to_process, to_pass_thru`
`491`	`491`