tests: set celery ping_task_timeout 3x the default (#8221)

tests: set celery ping_timeout 3x the default
This commit is contained in:
skshetry
2022-09-01 16:48:19 +05:45
committed by GitHub
parent aff65d42bb
commit 49da2eef02
+5 -1
View File
@@ -24,6 +24,10 @@ def test_queue(tmp_dir, dvc, scm, mocker) -> LocalCeleryQueue:
"""
celery_queue = dvc.experiments.celery_queue
mocker.patch.object(celery_queue, "spawn_worker")
with _thread_worker(celery_queue.celery, concurrency=1) as worker:
with _thread_worker(
celery_queue.celery,
concurrency=1,
ping_task_timeout=30,
) as worker:
mocker.patch.object(celery_queue, "worker", return_value=worker)
yield celery_queue