Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion tests/orchestrator/test_child_done_events.py
Original file line number Diff line number Diff line change
Expand Up @@ -224,7 +224,8 @@ async def _consume() -> None:
consumer_task = asyncio.create_task(_consume())

# Wait for: first turn (instant) + 50ms timeout + second turn (instant).
await asyncio.sleep(0.15)
# Use generous sleep to avoid flakiness on slow CI runners.
await asyncio.sleep(0.3)

# Close to unblock idle.
handle.close()
Expand Down
6 changes: 6 additions & 0 deletions tests/orchestrator/test_subagent_events.py
Original file line number Diff line number Diff line change
Expand Up @@ -564,6 +564,12 @@ async def test_nested_subagents_create_recursive_toolparts() -> None:
# But actually, the parent consumer subscribes with descendants scope to parent_id,
# and the spawn event for child would be published on parent_id by the agent runtime.
# Let's publish on parent_id.
# Wait for parent consumer to initialize before publishing depth=2 event.
for _ in range(50):
if parent_id in integration._contexts:
break
await asyncio.sleep(0.01)
await asyncio.sleep(0.05)
await _publish_spawn_event(
session_pool, parent_id, child_id, source_name="worker2", depth=2
)
Expand Down
Loading