fix(agent_server): Fix async issue with executor integration test (#7348)

Fix execution completed check
This commit is contained in:
Swifty
2024-07-09 12:09:44 +02:00
committed by GitHub
parent 7ce0c655d0
commit 57cc8b69e9

View File

@@ -65,7 +65,13 @@ async def execute_graph(test_manager: ExecutionManager, test_graph: graph.Graph)
execs = await agent_server.get_run_execution_results(
test_graph.id, graph_exec_id
)
return test_manager.queue.empty() and len(execs) == 4
return (
test_manager.queue.empty()
and len(execs) == 4
and all(
exec.status == execution.ExecutionStatus.COMPLETED for exec in execs
)
)
# Wait for the executions to complete
for i in range(10):