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

SIENTIAPDE-1148

Browse Source 
fix: improve error handling in temporal_manager.py by ensuring schedule_handles defaults to None and updating error messages for clarity
This commit is contained in:
vitor-aignosi
2025-07-11 11:04:30 -03:00
parent 7ad814408d
commit f3d9c1d685
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
orchestrator/activities/temporal_manager.py
View File

@@ -118,7 +118,8 @@ class TemporalManager(BaseActivity):
await sleep(0.1) await sleep(0.1)
self.logger.info("Found %d orchestrated schedules", self.logger.info("Found %d orchestrated schedules",
len(orchestrated_schedules)) len(orchestrated_schedules[self.scouter_namespace]) +
len(orchestrated_schedules[self.laborious_namespace]))
self.logger.debug("Orchestrated schedules: %s", self.logger.debug("Orchestrated schedules: %s",
orchestrated_schedules) orchestrated_schedules)
@@ -235,11 +236,11 @@ class TemporalManager(BaseActivity):
report = {} report = {}
for namespace, schedules in schedules_to_update.items(): for namespace, schedules in schedules_to_update.items():
schedule_handles = self.schedule_handles.get(namespace) schedule_handles = self.schedule_handles.get(namespace, None)
if not schedule_handles: if schedule_handles is None:
raise ValueError( raise ValueError(
f"Schedule handles for {namespace} not found, handles: {schedule_handles}") f"Schedule handles for {namespace} not found, handles: {self.schedule_handles}")
for schedule_name, schedule in schedules.items(): for schedule_name, schedule in schedules.items():
try: try:
@@ -311,11 +312,11 @@ class TemporalManager(BaseActivity):
report = {} report = {}
for namespace, schedules in schedules_to_delete.items(): for namespace, schedules in schedules_to_delete.items():
schedule_handles = self.schedule_handles.get(namespace) schedule_handles = self.schedule_handles.get(namespace, None)
if not schedule_handles: if schedule_handles is None:
raise ValueError( raise ValueError(
f"Schedule handles for {namespace} not found, handles: {schedule_handles}") f"Schedule handles for {namespace} not found, handles: {self.schedule_handles}")
for schedule_name in schedules: for schedule_name in schedules:
try: try: