fix: rename handler parameter input_data → event_data in calendar_sync queue handlers per INDEX.md convention
This commit is contained in:
@@ -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
|
||||
|
||||
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user