Skip to content

Commit 761b418

Browse files
authored
[Core] Deflake test_async_actor_task_retry in test_network_failure_e2e.py (#51415)
Signed-off-by: Mengjin Yan <mengjinyan3@gmail.com>
1 parent f29093e commit 761b418

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/ray/tests/test_network_failure_e2e.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ async def run(self):
260260
# first attempt
261261
await self.counter.inc.remote()
262262
while len(list_tasks(
263-
filters=[("name", "=", "AsyncActor.run")])) != 2:
263+
filters=[("name", "=", "AsyncActor.run")])) < 2:
264264
# wait for second attempt to be made
265265
await asyncio.sleep(1)
266266
# wait until the second attempt reaches the actor

0 commit comments

Comments
 (0)