Hi, I’m working on a task BEAM-3280 (Add typehints with TaggedOutput) and just want to clarify before I send a PR. https://issues.apache.org/jira/browse/BEAM-3280 <https://issues.apache.org/jira/browse/BEAM-3280>
Is it sufficient to modify the code in apache_beam.cookbook.multiple_output_pardo.py like below ? # with_outputs allows accessing the explicitly tagged outputs of a DoFn. split_lines_result = (lines | beam.ParDo(SplitLinesToWordsFn().with_output_types( beam.typehints.Tuple[ beam.typehints.Generator[unicode], beam.typehints.Generator[unicode], beam.typehints.Generator[int], ], )).with_outputs( SplitLinesToWordsFn.OUTPUT_TAG_SHORT_WORDS, SplitLinesToWordsFn.OUTPUT_TAG_CHARACTER_COUNT, main='words') ) Or do you expect something different to add a typehint to multiple outputs? Regards, Norio Akagi