[BEAM-14291] DataflowPipelineResult does not raise exception for unsuccessful states.

• Type: Bug
• Status: Open
• Priority: P1
• Resolution: Unresolved
• Component/s: runner-dataflow
• Assignee: Unassigned
• Reporter: Robert Bradshaw
• Created: 11/Apr/22 21:03
• Updated: 05/Jun/22 01:18

Description

An exception is correctly raised if wait_until_finish is called with a non-terminal state, but if the pipeline has already completed this check is skipped. See https://github.com/apache/beam/blob/release-2.37.0/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py#L1636