Add python test to reproduce a failed dofn. - #38476

Closed

shunping wants to merge 9 commits into

apache:masterfrom

shunping:add-deadline-exceed-python-test

Commits on May 13, 2026

Add python tests to reproduce a failed dofn and delayed worker shutdown.
shunping
committed
b61af0f
Gracefully handle control, message and data streams closing by runners.
shunping
committed
b4e4140
Add a grace period for worker clean-up after prism sending out shutdown signal.
shunping
committed
d557d8d
Reformat
shunping
committed
03dba37
Fix lints.
shunping
committed
28b0880
Remove short timeout
shunping
committed
ec4aca2
Do not swallow deadline exceed in data and message streams.
shunping
committed
09fb97c
Fix deadlock in multiprocessshared.
shunping
committed
1916301
Fix ml test crash.
shunping
committed
6f8613e