status-im
/
spiff-arena
mirror of https://github.com/status-im/spiff-arena.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge commit '71f8c94096534112c8a08f202f8bb0e6f81ed92f' into main

This commit is contained in:
Dan 2023-03-01 16:38:23 -05:00
parent d295e6ae94 71f8c94096
commit 8460e9b042
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
SpiffWorkflow/SpiffWorkflow/bpmn/specs/SubWorkflowTask.py
View File

@ -27,7 +27,6 @@ class SubWorkflowTask(BpmnSpecMixin):
def _on_ready_hook(self, my_task): def _on_ready_hook(self, my_task):
super()._on_ready_hook(my_task) super()._on_ready_hook(my_task)
self.start_workflow(my_task)
def _on_subworkflow_completed(self, subworkflow, my_task): def _on_subworkflow_completed(self, subworkflow, my_task):
self.update_data(my_task, subworkflow) self.update_data(my_task, subworkflow)
@ -38,7 +37,8 @@ class SubWorkflowTask(BpmnSpecMixin):
if my_task.id not in wf.subprocesses: if my_task.id not in wf.subprocesses:
super()._update_hook(my_task) super()._update_hook(my_task)
self.create_workflow(my_task) self.create_workflow(my_task)
return True self.start_workflow(my_task)
my_task._set_state(TaskState.WAITING)
def _on_cancel(self, my_task): def _on_cancel(self, my_task):
subworkflow = my_task.workflow.get_subprocess(my_task) subworkflow = my_task.workflow.get_subprocess(my_task)

4
SpiffWorkflow/SpiffWorkflow/spiff/specs/subworkflow_task.py
View File

@ -1,3 +1,4 @@
from SpiffWorkflow.task import TaskState
from SpiffWorkflow.bpmn.specs.SubWorkflowTask import ( from SpiffWorkflow.bpmn.specs.SubWorkflowTask import (
SubWorkflowTask as DefaultSubWorkflow, SubWorkflowTask as DefaultSubWorkflow,
TransactionSubprocess as DefaultTransaction, TransactionSubprocess as DefaultTransaction,
@ -24,7 +25,8 @@ class SubWorkflowTask(DefaultSubWorkflow, SpiffBpmnTask):
if my_task.id not in wf.subprocesses: if my_task.id not in wf.subprocesses:
SpiffBpmnTask._update_hook(self, my_task) SpiffBpmnTask._update_hook(self, my_task)
self.create_workflow(my_task) self.create_workflow(my_task)
return True self.start_workflow(my_task)
my_task._set_state(TaskState.WAITING)
def _on_complete_hook(self, my_task): def _on_complete_hook(self, my_task):
SpiffBpmnTask._on_complete_hook(self, my_task) SpiffBpmnTask._on_complete_hook(self, my_task)