From 49da2eef02e933b456378082d8d7c68cc7d4137a Mon Sep 17 00:00:00 2001 From: skshetry Date: Thu, 1 Sep 2022 16:48:19 +0545 Subject: [PATCH] tests: set celery ping_task_timeout 3x the default (#8221) tests: set celery ping_timeout 3x the default --- tests/unit/repo/experiments/conftest.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tests/unit/repo/experiments/conftest.py b/tests/unit/repo/experiments/conftest.py index d5ae0babc..2100049b4 100644 --- a/tests/unit/repo/experiments/conftest.py +++ b/tests/unit/repo/experiments/conftest.py @@ -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