potiuk commented on code in PR #66573:
URL: https://github.com/apache/airflow/pull/66573#discussion_r3264985582
##########
task-sdk/tests/task_sdk/execution_time/test_task_runner.py:
##########
@@ -475,6 +475,40 @@ def send_side_effect(msg=None, **kwargs):
assert error is None
+def test_run_exits_nonzero_when_failure_terminal_send_fails(create_runtime_ti,
mock_supervisor_comms):
Review Comment:
Added in 1b2449e:
`TestTaskRunnerCallsListeners::test_task_runner_calls_listeners_failed_when_terminal_send_fails`
— drives a failing operator with a broken-pipe `TaskState` send, then asserts
both that `_terminal_state_send_failed` was set and that the listener observed
`[RUNNING, FAILED]` after `finalize()`.
---
Drafted-by: Claude Code (Opus 4.7); reviewed by @potiuk before posting
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
