schedule waiting timer events after saving tasks because foreign keys (#1762)
Co-authored-by: burnettk <burnettk@users.noreply.github.com>
This commit is contained in:
parent
295c191c17
commit
bcf13bd46a
|
@ -472,7 +472,6 @@ class WorkflowExecutionService:
|
||||||
|
|
||||||
self.process_bpmn_messages()
|
self.process_bpmn_messages()
|
||||||
self.queue_waiting_receive_messages()
|
self.queue_waiting_receive_messages()
|
||||||
self.schedule_waiting_timer_events()
|
|
||||||
return task_runnability
|
return task_runnability
|
||||||
except WorkflowTaskException as wte:
|
except WorkflowTaskException as wte:
|
||||||
ProcessInstanceTmpService.add_event_to_process_instance(
|
ProcessInstanceTmpService.add_event_to_process_instance(
|
||||||
|
@ -493,6 +492,7 @@ class WorkflowExecutionService:
|
||||||
self.execution_strategy.add_object_to_db_session(self.bpmn_process_instance)
|
self.execution_strategy.add_object_to_db_session(self.bpmn_process_instance)
|
||||||
if save:
|
if save:
|
||||||
self.process_instance_saver()
|
self.process_instance_saver()
|
||||||
|
self.schedule_waiting_timer_events()
|
||||||
|
|
||||||
def is_happening_soon(self, time_in_seconds: int) -> bool:
|
def is_happening_soon(self, time_in_seconds: int) -> bool:
|
||||||
# if it is supposed to happen in less than the amount of time we take between polling runs
|
# if it is supposed to happen in less than the amount of time we take between polling runs
|
||||||
|
|
Loading…
Reference in New Issue