From c6996e04eabeb362a5711aedde39e86908703ddc Mon Sep 17 00:00:00 2001 From: bsiggel Date: Tue, 31 Mar 2026 07:09:58 +0000 Subject: [PATCH] =?UTF-8?q?fix:=20rename=20handler=20parameter=20input=5Fd?= =?UTF-8?q?ata=20=E2=86=92=20event=5Fdata=20in=20calendar=5Fsync=20queue?= =?UTF-8?q?=20handlers=20per=20INDEX.md=20convention?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/steps/advoware_cal_sync/calendar_sync_all_step.py | 4 ++-- src/steps/advoware_cal_sync/calendar_sync_event_step.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/steps/advoware_cal_sync/calendar_sync_all_step.py b/src/steps/advoware_cal_sync/calendar_sync_all_step.py index f743ae5..2e642c0 100644 --- a/src/steps/advoware_cal_sync/calendar_sync_all_step.py +++ b/src/steps/advoware_cal_sync/calendar_sync_all_step.py @@ -30,13 +30,13 @@ config = { } -async def handler(input_data: Dict[str, Any], ctx: FlowContext) -> None: +async def handler(event_data: Dict[str, Any], ctx: FlowContext) -> None: """ Handler that fetches all employees, sorts by last sync time, and emits calendar_sync_employee events for the oldest ones. """ try: - triggered_by = input_data.get('triggered_by', 'unknown') + triggered_by = event_data.get('triggered_by', 'unknown') ctx.logger.info(f"Calendar Sync All: Starting to emit events for oldest employees, triggered by {triggered_by}") # Initialize Advoware service diff --git a/src/steps/advoware_cal_sync/calendar_sync_event_step.py b/src/steps/advoware_cal_sync/calendar_sync_event_step.py index 7368e19..56534d5 100644 --- a/src/steps/advoware_cal_sync/calendar_sync_event_step.py +++ b/src/steps/advoware_cal_sync/calendar_sync_event_step.py @@ -949,11 +949,11 @@ config = { } -async def handler(input_data: Dict[str, Any], ctx: FlowContext) -> None: +async def handler(event_data: Dict[str, Any], ctx: FlowContext) -> None: """Main event handler for calendar sync.""" start_time = time.time() - kuerzel = input_data.get('kuerzel') + kuerzel = event_data.get('kuerzel') if not kuerzel: ctx.logger.error("No kuerzel provided in event") return