Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-14291

DataflowPipelineResult does not raise exception for unsuccessful states.

Details

    • Bug
    • Status: Open
    • P1
    • Resolution: Unresolved
    • None
    • None
    • runner-dataflow
    • None

    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

      Attachments

        Activity

          People

            Unassigned Unassigned
            robertwb Robert Bradshaw
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: