From bad848a1a45711c0a1f52eba8a9d36e665c70b88 Mon Sep 17 00:00:00 2001 From: Victor San Kho Lin Date: Sat, 24 Aug 2024 18:19:44 +1000 Subject: [PATCH] Fixed WorkflowRun State creation business logic * WorkflowRun State creation is WRSC timestamp dependant. It needs to check "time window" condition before saving and emitting (relaying) WRSC event. --- .../workflow_manager_proc/services/create_workflow_run.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/workload/stateless/stacks/workflow-manager/workflow_manager_proc/services/create_workflow_run.py b/lib/workload/stateless/stacks/workflow-manager/workflow_manager_proc/services/create_workflow_run.py index 267da069a..ca8ebe72d 100644 --- a/lib/workload/stateless/stacks/workflow-manager/workflow_manager_proc/services/create_workflow_run.py +++ b/lib/workload/stateless/stacks/workflow-manager/workflow_manager_proc/services/create_workflow_run.py @@ -69,7 +69,7 @@ def handler(event, context): wfr.save() # create the related state & payload entries for the WRSC - create_workflow_run_state(wrsc=wrsc, wfr=wfr) + # create_workflow_run_state(wrsc=wrsc, wfr=wfr) # FIXME State creation is "time window" WRSC timestamp dependant # if the workflow run is linked to library record(s), create the association(s) input_libraries: list[LibraryRecord] = wrsc.linkedLibraries