We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5a53862 commit 66684ddCopy full SHA for 66684dd
apps/ops/celery/signal_handler.py
@@ -2,6 +2,7 @@
2
#
3
import logging
4
import os
5
+import uuid_utils.compat as uuid
6
7
from celery import subtask
8
from celery.signals import (
@@ -36,7 +37,7 @@ def init_scheduler():
36
37
for job in trigger_jobs:
38
parts = job.id.split(':')
39
if len(parts) >= 2:
- trigger_id = parts[1] # 提取 trigger_id
40
+ trigger_id = uuid.UUID(parts[1]) # 提取 trigger_id
41
trigger_ids_from_jobs.add(trigger_id)
42
job_id_to_trigger_id[job.id] = trigger_id
43
0 commit comments