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