diff --git a/orchestrator/activities/temporal_manager.py b/orchestrator/activities/temporal_manager.py index 8ba86be..7d76176 100644 --- a/orchestrator/activities/temporal_manager.py +++ b/orchestrator/activities/temporal_manager.py @@ -118,7 +118,8 @@ class TemporalManager(BaseActivity): await sleep(0.1) 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", orchestrated_schedules) @@ -235,11 +236,11 @@ class TemporalManager(BaseActivity): report = {} 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( - 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(): try: @@ -311,11 +312,11 @@ class TemporalManager(BaseActivity): report = {} 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( - 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: try: