From 1833c1a7ffb0fbc04efde62a065a7290f10ace64 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Sat, 11 Feb 2023 18:32:41 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E5=90=AF=E5=85=B3=E9=97=AD=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/opm/services.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/apps/opm/services.py b/apps/opm/services.py index cc798a51..8650a583 100644 --- a/apps/opm/services.py +++ b/apps/opm/services.py @@ -123,9 +123,11 @@ def close_mtask(opl: Opl): """ from celery.app.control import Control from server.celery import app + celery_control = Control(app=app) + if opl.mtask_uid: + celery_control.revoke(opl.mtask_uid, terminate=True) qs = TaskResult.objects.filter(task_args__contains=opl.id, status__in=['PENDING', 'RECEIVED', 'STARTED']) if qs: - celery_control = Control(app=app) for i in qs: celery_control.revoke(i.task_id, terminate=True) opl.mtask_uid = None