zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

开启关闭任务优化

This commit is contained in:
caoqianming 2023-02-11 18:32:41 +08:00
parent 5a25bfe343
commit 1833c1a7ff
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/opm/services.py
View File

@ -123,9 +123,11 @@ def close_mtask(opl: Opl):
""" """
from celery.app.control import Control from celery.app.control import Control
from server.celery import app 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']) qs = TaskResult.objects.filter(task_args__contains=opl.id, status__in=['PENDING', 'RECEIVED', 'STARTED'])
if qs: if qs:
celery_control = Control(app=app)
for i in qs: for i in qs:
celery_control.revoke(i.task_id, terminate=True) celery_control.revoke(i.task_id, terminate=True)
opl.mtask_uid = None opl.mtask_uid = None