Skip to content

Commit a253fad

Browse files
authored
test: loop until result on A2A tests (#3233)
1 parent 4d9f5d7 commit a253fad

File tree

1 file changed

+11
-9
lines changed

1 file changed

+11
-9
lines changed

tests/test_a2a.py

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -560,11 +560,11 @@ def track_messages(messages: list[ModelMessage], info: AgentInfo) -> ModelRespon
560560
task1_id = result1['id']
561561
context_id = result1['context_id']
562562

563-
# Wait for first task to complete
564-
await anyio.sleep(0.1)
565-
task1 = await a2a_client.get_task(task1_id)
566-
assert 'result' in task1
567-
assert task1['result']['status']['state'] == 'completed'
563+
while task1 := await a2a_client.get_task(task1_id): # pragma: no branch
564+
if 'result' in task1 and task1['result']['status']['state'] == 'completed':
565+
result1 = task1['result']
566+
break
567+
await anyio.sleep(0.1)
568568

569569
# Verify the model received at least one message
570570
assert len(messages_received) == 1
@@ -668,11 +668,13 @@ def return_thinking_response(_: list[ModelMessage], info: AgentInfo) -> ModelRes
668668
task_id = result['id']
669669

670670
# Wait for completion
671-
await anyio.sleep(0.1)
672-
task = await a2a_client.get_task(task_id)
671+
while task := await a2a_client.get_task(task_id): # pragma: no branch
672+
if 'result' in task and task['result']['status']['state'] == 'completed':
673+
result = task['result']
674+
break
675+
await anyio.sleep(0.1)
673676

674-
assert 'result' in task
675-
assert task['result'] == snapshot(
677+
assert result == snapshot(
676678
{
677679
'id': IsStr(),
678680
'context_id': IsStr(),

0 commit comments

Comments
 (0)