[exec] Fixed multiple event inputs

gfalcone · gfalcone · commit 0a6bebdd67d0 · 2022-01-03T17:21:10.000+01:00
diff --git a/exec/src/klio_exec/commands/run.py b/exec/src/klio_exec/commands/run.py
@@ -476,7 +476,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
`@@ -476,7 +476,7 @@ def _generate_pcoll_per_input(self, pipeline):`
`476`	`476`	`to_process = MultiInputPCollTuple(**input_name_to_input_pcolls)`
`477`	`477`	`to_pass_thru = (`
`478`	`478`	`multi_to_pass_thru`
`479`		`- \| "Merge multi-input pass-thrus" >> beam.Flatten()`
	`479`	`+ \| "Merge multi-input pass-thrus" >> beam.Flatten(pipeline=pipeline)`
`480`	`480`	`)`
`481`	`481`	`return to_process, to_pass_thru`
`482`	`482`