[BEAM-10933] Dataflow specific pipeline updates are not reflected in the pipeline proto

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-dataflow
• Assignee: Unassigned
• Reporter: Chamikara Madhusanka Jayalath
• Created: 19/Sep/20 18:52
• Updated: 04/Jun/22 18:53

Description

More specifically the to visits here.

https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py#L566

 

These have to be done before creating the pipeline proto for Dataflow to be able to correctly generate job requests from portable protos.

 

Issue Links

• links to: GitHub Pull Request #12880