gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1150

Browse Source 
refactor: update orchestration workflow to conditionally execute pipeline timestamp handlers based on report flags, improving efficiency and clarity
This commit is contained in:
vitor-aignosi
2025-07-14 16:26:34 -03:00
parent 14e1366658
commit 5a421b80c0
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
orchestrator/workflows/orchestrator.py
View File

@@ -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