From 167cb00565245ee4a1dd9a1f41b515b195b393bd Mon Sep 17 00:00:00 2001 From: arthurhuang Date: Tue, 7 Jan 2025 15:18:06 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=94=B9revoke=E5=AF=BC?= =?UTF-8?q?=E5=85=A5=E6=96=B9=E5=BC=8F=20#1464?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pipeline/engine/models/core.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pipeline/engine/models/core.py b/pipeline/engine/models/core.py index ed8e2806..b065f0dd 100644 --- a/pipeline/engine/models/core.py +++ b/pipeline/engine/models/core.py @@ -17,7 +17,7 @@ import traceback from celery import current_app -from celery.task.control import revoke + from django.db import models, transaction from django.utils import timezone from django.utils.translation import gettext_lazy as _ @@ -34,6 +34,7 @@ from pipeline.log.models import LogEntry from pipeline.utils.uniqid import node_uniqid, uniqid +revoke = current_app.control.revoke logger = logging.getLogger("celery") RERUN_MAX_LIMIT = pipeline_settings.PIPELINE_RERUN_MAX_TIMES