From 44b0051a911300e8775bc569fbd17b9e6d547cc3 Mon Sep 17 00:00:00 2001 From: Nino Date: Mon, 6 Jan 2025 11:08:55 +0100 Subject: [PATCH] fix --- app/apps/workflow/models.py | 8 ++++---- app/apps/workflow/tasks.py | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/app/apps/workflow/models.py b/app/apps/workflow/models.py index 0d998a7..096ca9b 100644 --- a/app/apps/workflow/models.py +++ b/app/apps/workflow/models.py @@ -103,8 +103,7 @@ def start(self): ) ) - workflow = self._update_workflow(workflow) - self._update_db(workflow) + workflow = self.update_workflow(workflow) return def complete_user_task_and_create_new_user_tasks(self, task_id=None, data=None): @@ -117,7 +116,7 @@ def complete_user_task_and_create_new_user_tasks(self, task_id=None, data=None): task.set_data(**data) task.complete() - workflow = self._update_workflow(workflow) + workflow = self.update_workflow(workflow) self._update_db(workflow) def has_a_timer_event_fired(self): @@ -264,9 +263,10 @@ def _initial_data(self, wf, data): first_task.data.update(data) return wf - def _update_workflow(self, wf): + def update_workflow(self, wf): wf.refresh_waiting_tasks() wf.do_engine_steps() + self._update_db(wf) return wf def _update_db(self, wf): diff --git a/app/apps/workflow/tasks.py b/app/apps/workflow/tasks.py index bc4d7f6..db62520 100644 --- a/app/apps/workflow/tasks.py +++ b/app/apps/workflow/tasks.py @@ -36,7 +36,7 @@ def task_update_workflow(self, workflow_id): workflow_instance = CaseWorkflow.objects.get(id=workflow_id) with transaction.atomic(): - workflow_instance._update_workflow( + workflow_instance.update_workflow( workflow_instance._get_or_restore_workflow_state() ) return (