Fix flaky test output order (#3045)

2026-09-08 02:37:52 +02:00 · 2025-01-15 09:02:05 -08:00
parent f1ee650489 b7e4656c91
commit 4426552c26
1 changed files with 1 additions and 0 deletions
@@ -2456,6 +2456,7 @@ async def test_imp_task(checkpointer_name: str) -> None:
        async def mapper(input: int) -> str:
            nonlocal mapper_calls
            mapper_calls += 1
+            await asyncio.sleep(0.1 * input)
            return str(input) * 2

        @entrypoint(checkpointer=checkpointer)