Details
-
Improvement
-
Status: Triage Needed
-
P3
-
Resolution: Unresolved
-
None
-
None
-
None
Description
If there is an error when trying to contact the dataflow service in Python's Dataflow.poll_for_job_completion, we may exit the thread prematurely.
A typical manifestation is: Dataflow Runner fails with:
AssertionError: Job did not reach to a terminal state after waiting indefinitely.
however job execution continues, and succeeds.
Attachments
Issue Links
- is duplicated by
-
BEAM-7733 Flaky tests on Dataflow because of not found information about job state
- Resolved
- links to