diff --git a/orchestrator/activities/temporal_manager.py b/orchestrator/activities/temporal_manager.py index e29f49a..a191dae 100644 --- a/orchestrator/activities/temporal_manager.py +++ b/orchestrator/activities/temporal_manager.py @@ -249,7 +249,8 @@ class TemporalManager(BaseActivity): if not handler: raise ValueError(f"Schedule {schedule_name} not found") - async def update_schedule(input_data: ScheduleUpdateInput) -> ScheduleUpdate: + # fmt: off + async def update_schedule(input_data: ScheduleUpdateInput) -> ScheduleUpdate: # NOSONAR schedule_action = input_data.description.schedule.action self.logger.debug("Updating schedule:") @@ -257,7 +258,7 @@ class TemporalManager(BaseActivity): if hasattr(schedule_action, "args"): self.logger.debug("New schedule:") self.logger.debug(json.dumps( - schedule, indent=4, sort_keys=True)) + schedule, indent=4, sort_keys=True)) # NOSONAR schedule_action.args = [schedule] @@ -270,6 +271,7 @@ class TemporalManager(BaseActivity): return ScheduleUpdate(schedule=input_data.description.schedule) + # fmt: on await handler.update(update_schedule) del update_schedule