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

工单执行delay bug

This commit is contained in:
曹前明 2022-07-15 09:18:42 +08:00
parent 343e9e0434
commit 9ce68c02df
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/vm/tasks.py
View File

@ -10,7 +10,8 @@ from apps.wf.services import WfService
@shared_task(base=CustomTask) @shared_task(base=CustomTask)
def visit_exec(ticket, script_str): def visit_exec(ticket_id, script_str):
ticket = Ticket.objects.get(id=ticket_id)
ticket.script_run_last_result = False ticket.script_run_last_result = False
ticket.save() ticket.save()
visit = Visit.objects.get(ticket=ticket) visit = Visit.objects.get(ticket=ticket)

2
apps/wf/services.py
View File

@ -428,4 +428,4 @@ class WfService(object):
module, func = state.participant.rsplit(".", 1) module, func = state.participant.rsplit(".", 1)
m = importlib.import_module(module) m = importlib.import_module(module)
f = getattr(m, func) f = getattr(m, func)
f.delay(ticket=ticket, script_str=state.participant) # 里面要加入回调才能继续流转 f.delay(ticket_id=ticket.id, script_str=state.participant) # 里面要加入回调才能继续流转