diff --git a/tests/gateway/test_restart_resume_pending.py b/tests/gateway/test_restart_resume_pending.py index 9ac0142975..b36d5f73a6 100644 --- a/tests/gateway/test_restart_resume_pending.py +++ b/tests/gateway/test_restart_resume_pending.py @@ -964,8 +964,8 @@ async def test_restart_home_channel_notification_not_deduped_across_threads(): await runner._notify_active_sessions_of_shutdown() assert len(adapter.sent) == 2 - assert adapter.sent_calls[0][2] == {"thread_id": "topic-7"} - assert adapter.sent_calls[1][2] is None + assert adapter.sent_calls[0][2] == {"thread_id": "topic-7", "_interim_send": True} + assert adapter.sent_calls[1][2] == {"_interim_send": True} # ---------------------------------------------------------------------------