From 5a421b80c04b36d87cc5961b7a6782365db7e154 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Mon, 14 Jul 2025 16:26:34 -0300 Subject: [PATCH] SIENTIAPDE-1150 refactor: update orchestration workflow to conditionally execute pipeline timestamp handlers based on report flags, improving efficiency and clarity --- orchestrator/workflows/orchestrator.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/orchestrator/workflows/orchestrator.py b/orchestrator/workflows/orchestrator.py index 574f627..8d18fe0 100644 --- a/orchestrator/workflows/orchestrator.py +++ b/orchestrator/workflows/orchestrator.py @@ -234,6 +234,12 @@ class Orchestrator: await schedule_report_handler await slot_report_handler - await update_pipelines_timestamps_handler - await create_pipelines_timestamps_handler - await delete_pipelines_timestamps_handler + + if schedule_update_report: + await update_pipelines_timestamps_handler + + if schedule_insertion_report: + await create_pipelines_timestamps_handler + + if schedule_deletion_report: + await delete_pipelines_timestamps_handler