From 545929c61860f38dc30ae9509a8b414ef73b5fda Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Wed, 9 Jul 2025 12:33:12 -0300 Subject: [PATCH] SIENTIAPDE-1141 feat: add asynchronous sleep in temporal_manager to improve schedule processing --- orchestrator/activities/temporal_manager.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/orchestrator/activities/temporal_manager.py b/orchestrator/activities/temporal_manager.py index 34c0a21..ab1cb29 100644 --- a/orchestrator/activities/temporal_manager.py +++ b/orchestrator/activities/temporal_manager.py @@ -1,3 +1,4 @@ +from asyncio import sleep from temporalio import activity, workflow from temporalio.client import ( Client, Schedule, ScheduleActionStartWorkflow, ScheduleIntervalSpec, ScheduleSpec, ScheduleUpdate, ScheduleUpdateInput) @@ -77,6 +78,8 @@ class TemporalManager(BaseActivity): 'data': json.loads(data), } + await sleep(0.075) + self.logger.info("Found %d orchestrated schedules", len(orchestrated_schedules))