Skip to content

Commit 5e7b881

Browse files
committed
set a timeout
1 parent fe1ee67 commit 5e7b881

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

services/director-v2/tests/unit/test_modules_dask_client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -737,10 +737,10 @@ def fake_remote_fct(
737737
with pytest.raises(TaskCancelledError):
738738
await dask_client.get_task_result(published_computation_task[0].job_id)
739739

740-
await asyncio.sleep(5)
741740
await dask_client.release_task_result(published_computation_task[0].job_id)
742741
# after releasing the results, the task shall be UNKNOWN
743-
742+
_ALLOW_TIME_FOR_LOCAL_DASK_SCHEDULER_TO_UPDATE_TIMEOUT_S = 5
743+
await asyncio.sleep(_ALLOW_TIME_FOR_LOCAL_DASK_SCHEDULER_TO_UPDATE_TIMEOUT_S)
744744
# NOTE: this change of status takes a very long time to happen and is not relied upon so we skip it since it
745745
# makes the test fail a lot for no gain (it's kept here in case it ever becomes an issue)
746746
await _assert_wait_for_task_status(

0 commit comments

Comments
 (0)