Teknium
0cbc4ce83b
fix(streaming): gate the interrupt worker join on live Relay managed execution
...
The unconditional 2s join before InterruptedError delayed interrupt
detection when Relay managed execution was not active (CI:
tests/run_agent/test_interrupt_propagation.py — detection took 2.34s
against a <1.0s budget, because the mocked worker sleeps 5s and there
is no Relay scope to unwind).
Extract the join into _join_worker_for_relay_teardown(), which no-ops
unless a Relay runtime exists AND managed execution consumers are
registered — the only case where an orphaned physical scope can corrupt
the LIFO stack (#81521 ). Applied at all three interrupt sites
(streaming, non-streaming, Bedrock streaming). The regression test now
simulates a live runtime so the join path stays covered.
2026-08-14 22:11:30 -07:00
..
2026-08-01 21:17:51 -04:00
2026-08-08 18:11:02 -07:00
2026-07-05 13:42:46 -07:00
2026-07-24 11:45:57 -07:00
2026-08-12 19:13:32 -07:00
2026-08-14 21:25:48 -07:00
2026-08-07 10:11:05 -07:00
2026-05-28 00:20:11 -07:00
2026-07-22 10:58:22 -07:00
2026-08-15 10:29:05 +05:30
2026-08-15 10:29:05 +05:30
2026-08-14 21:27:05 -07:00
2026-07-18 20:01:55 +05:30
2026-07-16 04:23:12 -07:00
2026-08-14 22:04:16 -07:00
2026-08-02 10:02:33 -07:00
2026-07-26 23:41:54 -07:00
2026-08-09 16:13:52 +05:30
2026-07-21 13:54:11 -05:00
2026-07-23 11:45:07 -07:00
2026-07-22 18:08:59 -05:00
2026-07-29 11:53:39 -07:00
2026-07-29 11:53:39 -07:00
2026-07-05 14:00:20 -07:00
2026-08-10 10:45:44 -07:00
2026-08-12 19:13:32 -07:00
2026-08-14 22:11:30 -07:00
2026-08-14 10:39:25 -07:00
2026-08-12 12:42:39 +05:30
2026-07-29 15:28:15 -07:00
2026-07-26 18:06:21 -07:00
2026-08-14 20:52:16 -07:00
2026-08-08 23:09:45 +05:30
2026-08-12 18:41:59 -07:00
2026-08-15 10:22:47 +05:30
2026-08-14 22:04:16 -07:00
2026-08-12 11:04:45 -07:00
2026-07-02 13:17:41 -07:00
2026-08-14 21:54:56 -07:00
2026-08-08 12:32:23 -07:00
2026-07-28 21:36:23 +00:00
2026-08-08 15:10:35 +05:30
2026-08-03 18:21:17 +05:30
2026-08-13 13:53:39 +05:30
2026-08-06 03:16:26 +05:30
2026-08-13 09:34:36 -07:00
2026-08-14 21:54:56 -07:00
2026-07-17 13:49:12 -07:00
2026-08-08 05:21:09 -07:00
2026-08-12 11:04:45 -07:00
2026-08-05 17:21:01 -07:00
2026-07-26 20:59:16 -07:00
2026-07-29 15:28:15 -07:00
2026-08-08 14:49:28 -07:00
2026-08-12 19:13:32 -07:00
2026-08-14 03:31:22 +05:30
2026-08-14 02:04:24 +05:30
2026-08-02 22:15:20 +05:30
2026-07-26 12:54:45 -07:00
2026-05-28 00:20:11 -07:00
2026-07-14 16:47:33 +05:30
2026-08-08 05:09:43 -07:00
2026-07-29 11:53:39 -07:00
2026-07-01 16:25:48 -05:00
2026-06-30 15:16:21 -05:00
2026-07-16 07:57:51 -07:00
2026-07-23 08:19:14 -07:00
2026-08-13 23:43:15 +05:30
2026-08-13 23:15:25 +05:30
2026-06-19 15:23:41 +08:00
2026-08-07 16:57:11 +05:30
2026-08-13 23:10:16 +05:30
2026-08-13 23:10:16 +05:30
2026-08-14 16:37:36 -07:00
2026-08-14 03:31:22 +05:30
2026-07-20 11:05:52 -07:00
2026-08-13 03:04:45 -07:00
2026-07-24 17:10:39 -07:00
2026-07-22 12:10:58 -05:00
2026-06-23 08:01:50 +00:00
2026-08-02 15:01:11 -07:00
2026-08-12 16:25:20 -07:00
2026-08-12 18:38:25 -07:00
2026-07-16 01:13:43 -07:00
2026-07-05 03:14:55 -07:00
2026-08-14 21:54:56 -07:00
2026-08-09 15:25:12 +05:30
2026-08-13 15:24:47 +05:30
2026-07-10 05:41:59 -05:00
2026-08-06 22:02:37 -05:00
2026-08-12 13:37:04 -04:00
2026-08-13 23:10:16 +05:30
2026-08-08 23:46:17 -07:00
2026-08-14 22:11:30 -07:00
2026-08-08 23:46:17 -07:00
2026-07-19 08:25:35 +05:30
2026-07-29 10:13:50 -07:00
2026-07-16 04:32:23 -07:00
2026-08-02 09:59:52 -07:00
2026-08-02 16:16:36 -07:00
2026-08-13 09:36:02 -07:00
2026-07-29 12:20:34 -07:00
2026-08-09 15:25:12 +05:30
2026-07-29 15:28:15 -07:00
2026-08-06 03:16:26 +05:30
2026-08-08 15:10:24 +05:30
2026-07-02 04:51:56 +05:30
2026-05-28 04:53:27 -07:00
2026-07-17 18:31:09 +00:00
2026-08-02 22:15:20 +05:30
2026-08-03 20:43:34 +05:30
2026-07-22 08:11:09 +05:30
2026-08-14 14:37:00 -07:00
2026-07-16 01:07:29 +05:30
2026-06-25 19:00:48 -07:00
2026-08-06 23:08:23 -05:00
2026-08-09 04:33:58 -05:00
2026-08-03 22:53:32 +05:30
2026-08-14 21:20:03 -07:00
2026-08-13 09:34:36 -07:00
2026-07-11 05:41:58 -07:00
2026-08-14 21:41:26 -07:00
2026-08-12 19:01:30 -07:00
2026-08-12 19:13:32 -07:00
2026-05-24 18:04:54 -07:00
2026-08-12 19:13:32 -07:00
2026-08-13 23:15:25 +05:30
2026-08-15 03:22:16 +05:30
2026-08-08 11:24:45 -07:00
2026-07-26 17:47:51 -07:00
2026-08-14 22:04:16 -07:00
2026-08-07 10:11:05 -07:00
2026-08-12 01:15:25 -07:00
2026-06-30 00:59:29 -05:00
2026-07-02 06:07:56 +05:30
2026-08-08 14:49:28 -07:00
2026-08-12 19:13:32 -07:00
2026-07-06 02:42:24 -07:00
2026-08-12 19:13:32 -07:00