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

作业开启监控时保证可以获取到

This commit is contained in:
曹前明 2022-09-12 19:35:40 +08:00
parent 38f77c78f5
commit 735ba1e977
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/opm/services.py
View File

@ -1,4 +1,5 @@
import time
from apps.ecm.service import check_not_in_place from apps.ecm.service import check_not_in_place
from apps.ecm.tasks import opl_task from apps.ecm.tasks import opl_task
from apps.opm.models import Operation, Opl, OplWorker from apps.opm.models import Operation, Opl, OplWorker
@ -100,6 +101,7 @@ def start_mtask(opl: Opl):
vc_codes = list(op.vchannels.all().values_list('code', flat=True)) vc_codes = list(op.vchannels.all().values_list('code', flat=True))
opl_id = opl.id opl_id = opl.id
task = opl_task.delay(vc_codes, opl_id) task = opl_task.delay(vc_codes, opl_id)
time.sleep(3)
opl.mtask = TaskResult.objects.get(task_id=task.task_id) opl.mtask = TaskResult.objects.get(task_id=task.task_id)
opl.save() opl.save()