Robert Bradshaw created BEAM-3393: ------------------------------------- Summary: Empty flattens cannot be used as side inputs. Key: BEAM-3393 URL: https://issues.apache.org/jira/browse/BEAM-3393 Project: Beam Issue Type: Bug Components: sdk-py-core Reporter: Robert Bradshaw Assignee: Ahmet Altay
{{with beam.Pipeline() as p: main = p | "CM" >> beam.Create([]) side1 = p | "C1" >> beam.Create([]) side2 = p | "C2" >> beam.Create([]) side = (side1, side2) | beam.Flatten() res = main | beam.Map(lambda x, side: x, beam.pvalue.AsList(side)) }} results in {{ File "/Users/robertwb/Work/beam/incubator-beam/sdks/python/apache_beam/runners/direct/evaluation_context.py", line 84, in add_values assert not view.has_result }} -- This message was sent by Atlassian JIRA (v6.4.14#64029)