SIENTIAPDE-1141

feat: add asynchronous sleep in temporal_manager to improve schedule processing
This commit is contained in:
vitor-aignosi
2025-07-09 12:33:12 -03:00
parent 9d63647cf1
commit 545929c618

View File

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