diff --git a/apps/vm/tasks.py b/apps/vm/tasks.py index e3190f36..9c08b51c 100644 --- a/apps/vm/tasks.py +++ b/apps/vm/tasks.py @@ -10,7 +10,8 @@ from apps.wf.services import WfService @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.save() visit = Visit.objects.get(ticket=ticket) diff --git a/apps/wf/services.py b/apps/wf/services.py index e3596c53..ebc840a4 100755 --- a/apps/wf/services.py +++ b/apps/wf/services.py @@ -428,4 +428,4 @@ class WfService(object): module, func = state.participant.rsplit(".", 1) m = importlib.import_module(module) f = getattr(m, func) - f.delay(ticket=ticket, script_str=state.participant) # 里面要加入回调才能继续流转 + f.delay(ticket_id=ticket.id, script_str=state.participant) # 里面要加入回调才能继续流转