File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -93,7 +93,9 @@ def wait_for_complete_response(context: Context) -> None:
9393 """Wait for the response to be complete."""
9494 context .response_data = _parse_streaming_response (context .response .text )
9595 context .response .raise_for_status ()
96- assert context .response_data ["finished" ] is True , f"Response is not finished: { context .response_data } "
96+ assert (
97+ context .response_data ["finished" ] is True
98+ ), f"Response is not finished: { context .response_data } "
9799
98100
99101@step ('I use "{endpoint}" to ask question' )
@@ -366,7 +368,6 @@ def _parse_streaming_response(response_text: str) -> dict:
366368 full_response = ""
367369 full_response_split = []
368370 finished = False
369- first_token = True
370371 stream_error = (
371372 None # {"status_code": int, "response": str, "cause": str} if event "error"
372373 )
@@ -380,10 +381,6 @@ def _parse_streaming_response(response_text: str) -> dict:
380381 if event == "start" :
381382 conversation_id = data ["data" ]["conversation_id" ]
382383 elif event == "token" :
383- # Skip the first token (shield status message)
384- if first_token :
385- first_token = False
386- continue
387384 full_response_split .append (data ["data" ]["token" ])
388385 elif event == "turn_complete" :
389386 full_response = data ["data" ]["token" ]
Original file line number Diff line number Diff line change 1+ features/authorized_noop.feature
2+ features/health.feature
3+ features/info.feature
4+ features/models.feature
5+ features/rest_api.feature
6+ features/smoketests.feature
7+ features/authorized_noop_token.feature
8+ features/conversation_cache_v2.feature
9+ features/conversations.feature
10+ features/prompts.feature
11+ features/faiss.feature
12+ features/inline_rag.feature
13+ features/feedback.feature
14+ features/query.feature
15+ features/responses.feature
16+ features/responses_streaming.feature
17+ features/rlsapi_v1.feature
118features/streaming_query.feature
19+ features/http_401_unauthorized.feature
20+ features/authorized_rh_identity.feature
21+ features/rbac.feature
22+ features/rlsapi_v1_errors.feature
23+ features/llama_stack_disrupted.feature
24+ features/mcp.feature
25+ features/mcp_servers_api.feature
26+ features/mcp_servers_api_auth.feature
27+ features/mcp_servers_api_no_config.feature
28+ features/proxy.feature
29+ features/tls.feature
30+ features/opentelemetry.feature
You can’t perform that action at this time.
0 commit comments