The GitHub Actions job "Tests (AMD)" on 
airflow.git/refactor/go-sdk/coordinator-runtime-server has failed.
Run started by GitHub user jason810496 (triggered by jason810496).

Head commit for run:
a6b5ff85415130221dc435b4ac7622ad13ba795e / LIU ZHE YOU <[email protected]>
Cancel coordinator-mode tasks on SIGINT/SIGTERM

The coordinator runtime ran each task under a fresh context.Background(),
so a supervisor shutdown could not reach the task: SIGTERM terminated the
process outright and a cooperative task had no chance to observe the
shutdown and return. The final-frame write was also unbounded, so a
half-open comm socket could wedge the runtime indefinitely.

Derive the task's root context from signal.NotifyContext(SIGINT,
SIGTERM) in Serve and thread it through RunTask into the user task, so a
ctx-aware task returns promptly on a supervisor shutdown; a task that
ignores ctx is still stopped by the supervisor's follow-up SIGKILL.
Bound the terminal frame write with a deadline so a wedged socket fails
fast (non-zero exit) instead of hanging. An in-flight client call is
unaffected: it already unblocks on supervisor disconnect via the comm
dispatcher's ErrDispatcherClosed path.

Adds a test that a cancelled root context reaches the user task through
RunTask and is reported as a failed terminal state.

Report URL: https://github.com/apache/airflow/actions/runs/26707794702

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to