From ec17ed7b587cf6ee143646baaee67a7c017044d4 Mon Sep 17 00:00:00 2001 From: Igor Monadical Date: Thu, 4 Dec 2025 09:22:51 -0500 Subject: [PATCH] fix: celery inspect bug sidestep in restart script (#766) * celery bug sidestep * Update server/reflector/services/transcript_process.py Co-authored-by: pr-agent-monadical[bot] <198624643+pr-agent-monadical[bot]@users.noreply.github.com> --------- Co-authored-by: Igor Loskutov Co-authored-by: pr-agent-monadical[bot] <198624643+pr-agent-monadical[bot]@users.noreply.github.com> --- server/reflector/services/transcript_process.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/reflector/services/transcript_process.py b/server/reflector/services/transcript_process.py index 746ca3ea..2f91b65b 100644 --- a/server/reflector/services/transcript_process.py +++ b/server/reflector/services/transcript_process.py @@ -160,7 +160,10 @@ def dispatch_transcript_processing(config: ProcessingConfig) -> AsyncResult: def task_is_scheduled_or_active(task_name: str, **kwargs): inspect = celery.current_app.control.inspect() - for worker, tasks in (inspect.scheduled() | inspect.active()).items(): + scheduled = inspect.scheduled() or {} + active = inspect.active() or {} + all = scheduled | active + for worker, tasks in all.items(): for task in tasks: if task["name"] == task_name and task["kwargs"] == kwargs: return True