test(cron): assert buffered stream suppression

maintainer edit: keep the regression focused on the observable leak: rejected streaming cron output must not publish outbound events before delivery approval.
This commit is contained in:
chengyongru 2026-06-03 16:56:14 +08:00
parent b5db9fcd52
commit f57a670ef8

View File

@ -1601,7 +1601,6 @@ def test_gateway_cron_job_streaming_respects_evaluator_rejection(
assert response == "This should not leak"
assert seen["on_stream"] is not None
assert seen["on_stream_end"] is not None
assert seen["evaluated"] is True
bus.publish_outbound.assert_not_awaited()