fix/crash-child-task-runs-19594 - Branch - PrefectHQ/prefect

fix: crash child task runs when parent flow run crashes

#19600

Comparing

fix/crash-child-task-runs-19594

(

cc2238d

) with

main

(

dd875ab

)

Untouched: 2

Ignored: 6

Benchmarks

Passed

bench_task_decorator

benches/bench_tasks.py

460 µs459.9 µs

bench_import_prefect_flow

benches/bench_import.py

1.4 s1.4 s

Ignored

bench_flow_call[options1]

benches/bench_flows.py

Ignored

107.5 ms107.7 ms

bench_flow_decorator

benches/bench_flows.py

Ignored

-1%

5.9 ms6 ms

bench_flow_call[options0]

benches/bench_flows.py

Ignored

167 ms166.6 ms

bench_import_prefect

benches/bench_import.py

Ignored

1.1 s1.1 s

bench_task_call

benches/bench_tasks.py

Ignored

-6%

153.5 ms163.3 ms

bench_task_submit

benches/bench_tasks.py

Ignored

×3.1

7.6 ms2.5 ms

Commits

Click on a commit to change the comparison range

Base

main

dd875ab

-0.01%

fix: crash child task runs when parent flow run crashes When a flow run transitions to CRASHED state (e.g., OOM killed in Kubernetes), automatically transition all non-terminal child task runs to CRASHED as well. This ensures task runs don't remain stuck in RUNNING state when their parent flow crashes. Adds `CrashChildTaskRuns` transform to `GlobalFlowPolicy`, following the same pattern as `UpdateSubflowParentTask`. Fixes #19594 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>

cb0ee2b

8 hours ago

by zzstoatzz

refactor: improve integration tests for crash child task runs - Add proper docstrings explaining why API-level testing is appropriate - Add test for preserving already-completed tasks - Add test for crashing pending tasks - Clean up test structure and imports 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>

cc2238d

7 hours ago

by zzstoatzz

Home Terms Privacy Docs