@@ -155,35 +155,44 @@ async def test_should_not_produce_deltas_after_session_resume_with_streaming_dis
155155 finally :
156156 await new_client .force_stop ()
157157
158- async def test_should_emit_streaming_deltas_with_reasoning_effort_configured (
159- self , ctx : E2ETestContext
160- ):
158+ async def test_should_emit_streaming_deltas_with_reasoning_effort_configured (self ):
161159 """Streaming + reasoning_effort produces delta events and session.start shows effort."""
162160 from copilot .session_events import SessionStartData
163161
164- session = await ctx .client .create_session (
165- on_permission_request = PermissionHandler .approve_all ,
166- model = "gpt-5.4" ,
167- streaming = True ,
168- reasoning_effort = "high" ,
169- )
170-
171- events = []
172- session .on (lambda event : events .append (event ))
173-
162+ isolated_ctx = E2ETestContext ()
163+ await isolated_ctx .setup ()
174164 try :
175- await session .send_and_wait ("What is 15 * 17?" , timeout = 60.0 )
176-
177- delta_events = [e for e in events if e .type .value == "assistant.message_delta" ]
178- assert len (delta_events ) >= 1 , "Expected delta events with streaming=True"
179-
180- assistant_events = [e for e in events if e .type .value == "assistant.message" ]
181- assert len (assistant_events ) >= 1 , "Expected final assistant.message"
165+ await isolated_ctx .configure_for_test (
166+ "streaming_fidelity" ,
167+ "should_emit_streaming_deltas_with_reasoning_effort_configured" ,
168+ )
169+ session = await isolated_ctx .client .create_session (
170+ on_permission_request = PermissionHandler .approve_all ,
171+ model = "gpt-5.4" ,
172+ streaming = True ,
173+ reasoning_effort = "high" ,
174+ )
182175
183- # Check session.start event (from get_events) has reasoning_effort
184- all_msgs = await session .get_events ()
185- start_event = next ((e for e in all_msgs if isinstance (e .data , SessionStartData )), None )
186- assert start_event is not None , "Expected session.start event"
187- assert start_event .data .reasoning_effort == "high"
176+ events = []
177+ session .on (lambda event : events .append (event ))
178+
179+ try :
180+ await session .send_and_wait ("What is 15 * 17?" , timeout = 60.0 )
181+
182+ delta_events = [e for e in events if e .type .value == "assistant.message_delta" ]
183+ assert len (delta_events ) >= 1 , "Expected delta events with streaming=True"
184+
185+ assistant_events = [e for e in events if e .type .value == "assistant.message" ]
186+ assert len (assistant_events ) >= 1 , "Expected final assistant.message"
187+
188+ # Check session.start event (from get_events) has reasoning_effort
189+ all_msgs = await session .get_events ()
190+ start_event = next (
191+ (e for e in all_msgs if isinstance (e .data , SessionStartData )), None
192+ )
193+ assert start_event is not None , "Expected session.start event"
194+ assert start_event .data .reasoning_effort == "high"
195+ finally :
196+ await session .disconnect ()
188197 finally :
189- await session . disconnect ()
198+ await isolated_ctx . teardown ()
0 commit comments