Skip to content

Commit 8bc730e

Browse files
authored
test: loop until result on A2A tests (#3182)
1 parent c5b1495 commit 8bc730e

File tree

1 file changed

+14
-6
lines changed

1 file changed

+14
-6
lines changed

tests/test_a2a.py

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -893,9 +893,13 @@ async def test_a2a_multiple_send_task_messages():
893893
task_id = result['id']
894894
context_id = result['context_id']
895895

896-
await anyio.sleep(0.1)
897-
response = await a2a_client.get_task(task_id)
898-
assert response.get('result') == snapshot(
896+
while task := await a2a_client.get_task(task_id): # pragma: no branch
897+
if 'result' in task and task['result']['status']['state'] == 'completed':
898+
result = task['result']
899+
break
900+
await anyio.sleep(0.1)
901+
902+
assert result == snapshot(
899903
{
900904
'id': IsStr(),
901905
'context_id': IsStr(),
@@ -958,9 +962,13 @@ async def test_a2a_multiple_send_task_messages():
958962
}
959963
)
960964

961-
await anyio.sleep(0.1)
962-
response = await a2a_client.get_task(task_id)
963-
assert response.get('result') == snapshot(
965+
while task := await a2a_client.get_task(task_id): # pragma: no branch
966+
if 'result' in task and task['result']['status']['state'] == 'completed':
967+
result = task['result']
968+
break
969+
await anyio.sleep(0.1) # pragma: lax no cover
970+
971+
assert result == snapshot(
964972
{
965973
'id': IsStr(),
966974
'context_id': IsStr(),

0 commit comments

Comments
 (0)