From 4ab7ef06e5eab6bb51a501c2ad0600102cd62382 Mon Sep 17 00:00:00 2001 From: Peter Rowlands Date: Thu, 27 Apr 2023 17:52:00 +0900 Subject: [PATCH] exp: pass -v loglevel into dvc-task workers --- dvc/repo/experiments/queue/celery.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dvc/repo/experiments/queue/celery.py b/dvc/repo/experiments/queue/celery.py index 1ca787719..70693abb7 100644 --- a/dvc/repo/experiments/queue/celery.py +++ b/dvc/repo/experiments/queue/celery.py @@ -125,6 +125,7 @@ class LocalCeleryQueue(BaseStashQueue): without_mingle=True, without_gossip=True, timeout=10, + loglevel="debug" if logger.getEffectiveLevel() <= logging.DEBUG else "info", ) def _spawn_worker(self, num: int = 1): @@ -143,6 +144,8 @@ class LocalCeleryQueue(BaseStashQueue): if num == 1: # automatically run celery cleanup when primary worker shuts down cmd.append("--clean") + if logger.getEffectiveLevel() <= logging.DEBUG: + cmd.append("-v") name = f"dvc-exp-worker-{num}" logger.debug("start a new worker: %s, node: %s", name, node_name)