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

Dataflow runner raises AssertionError if job takes > 50 seconds to go from PENDING to RUNNING

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • 2.6.0
    • 2.8.0
    • sdk-py-core
    • None

    Description

      To reproduce:

      I think the issue is that the block at https://github.com/apache/beam/blob/766a1dc5b6523a0b7a3ce0a9ab78901cf17c9013/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py#L147-L160 unintentionally exits if it takes > 50 seconds for a job to go from JOB_STATE_PENDING to JOB_STATE_RUNNING.

      Attachments

        Issue Links

          Activity

            People

              altay Ahmet Altay
              joar Joar Wandborg
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 4h
                  4h