Fix flaky test

This commit is contained in:
Nuno Campos
2024-09-17 10:52:39 -07:00
parent f03dc2f006
commit da901b01d8
@@ -7011,6 +7011,9 @@ async def test_stream_subgraphs_during_execution(checkpointer_name: str) -> None
config = {"configurable": {"thread_id": "2"}}
async for c in app.astream({"my_key": ""}, config, subgraphs=True):
chunks.append((round(perf_counter() - start, 1), c))
for idx in range(len(chunks)):
elapsed, c = chunks[idx]
chunks[idx] = (round(elapsed - chunks[0][0], 1), c)
assert chunks == [
# arrives before "inner" finishes