Attempt to recover when a run is terminated between being dequeued and…
db32d153ca5d
Actions

Description

Attempt to recover when a run is terminated between being dequeued and execution is started

Summary: This isn't perfect, but should help with the case where we hard-terminate a run while it's in the middle of being popped off of the queue. Hopefully a rare case in the first place.

Test Plan: BK

Reviewers: johann, alangenfeld

Reviewed By: johann

Differential Revision: https://dagster.phacility.com/D5477

Details

Provenance

• dgibson

Authored on Dec 16 2020, 11:00 PM

Reviewer

• johann

Differential Revision

D5477: Attempt to recover when a run is terminated between being dequeued and execution is started

Parents

R1:644d62024e00: Summary: Misc small Dagit fixes - #3343, #2568, #1015

Branches

Unknown

Tags

Unknown

Event Timeline

• dgibson committed R1:db32d153ca5d: Attempt to recover when a run is terminated between being dequeued and… (authored by • dgibson).Dec 17 2020, 3:18 PM

• dgibson added an edge: D5477: Attempt to recover when a run is terminated between being dequeued and execution is started.

Changes (2)

Path

Size

python_modules/

dagster/

core/

execution/

api.py

dagster_tests/

core_tests/

execution_tests/

test_api_iterators.py

R1:db32d153ca5d

View Options

python_modules/dagster/dagster/core/execution/api.py