From 02821496130d999593c213a65424418715a929fd Mon Sep 17 00:00:00 2001 From: bsiggel Date: Mon, 2 Mar 2026 09:36:09 +0000 Subject: [PATCH] Fix cron expression in Calendar Sync Cron Job to trigger at second 0 and update entity retrieval methods in Beteiligte Sync steps for consistency --- steps/advoware_cal_sync/calendar_sync_cron_step.py | 2 +- steps/vmh/beteiligte_sync_cron_step.py | 6 +++--- steps/vmh/beteiligte_sync_event_step.py | 6 +++--- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/steps/advoware_cal_sync/calendar_sync_cron_step.py b/steps/advoware_cal_sync/calendar_sync_cron_step.py index f69cd28..c2594ed 100644 --- a/steps/advoware_cal_sync/calendar_sync_cron_step.py +++ b/steps/advoware_cal_sync/calendar_sync_cron_step.py @@ -17,7 +17,7 @@ config = { 'description': 'Runs calendar sync automatically every 15 minutes', 'flows': ['advoware-calendar-sync'], 'triggers': [ - cron("*/15 * * * * *") # Every 15 minutes at second 0 (6-field: sec min hour day month weekday) + cron("0 */15 * * * *") # Every 15 minutes at second 0 (6-field: sec min hour day month weekday) ], 'enqueues': ['calendar_sync_all'] } diff --git a/steps/vmh/beteiligte_sync_cron_step.py b/steps/vmh/beteiligte_sync_cron_step.py index a05b3da..f1e07b3 100644 --- a/steps/vmh/beteiligte_sync_cron_step.py +++ b/steps/vmh/beteiligte_sync_cron_step.py @@ -54,7 +54,7 @@ async def handler(input_data: Dict[str, Any], ctx: FlowContext): ] } - unclean_result = await espocrm.search_entities('CBeteiligte', unclean_filter, max_size=100) + unclean_result = await espocrm.list_entities('CBeteiligte', where=unclean_filter['where'], max_size=100) unclean_entities = unclean_result.get('list', []) ctx.logger.info(f"📊 Gefunden: {len(unclean_entities)} Entities mit Status pending/dirty/failed") @@ -73,7 +73,7 @@ async def handler(input_data: Dict[str, Any], ctx: FlowContext): ] } - reset_result = await espocrm.search_entities('CBeteiligte', permanently_failed_filter, max_size=50) + reset_result = await espocrm.list_entities('CBeteiligte', where=permanently_failed_filter['where'], max_size=50) reset_entities = reset_result.get('list', []) # Reset permanently_failed entities @@ -111,7 +111,7 @@ async def handler(input_data: Dict[str, Any], ctx: FlowContext): ] } - stale_result = await espocrm.search_entities('CBeteiligte', stale_filter, max_size=50) + stale_result = await espocrm.list_entities('CBeteiligte', where=stale_filter['where'], max_size=50) stale_entities = stale_result.get('list', []) ctx.logger.info(f"📊 Gefunden: {len(stale_entities)} Entities mit veraltetem Sync (> 24h)") diff --git a/steps/vmh/beteiligte_sync_event_step.py b/steps/vmh/beteiligte_sync_event_step.py index 33ef795..8f92384 100644 --- a/steps/vmh/beteiligte_sync_event_step.py +++ b/steps/vmh/beteiligte_sync_event_step.py @@ -37,9 +37,9 @@ config = { async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]): """Zentraler Sync-Handler für Beteiligte""" - entity_id = event_data.entity_id - action = event_data.action - source = event_data.source + entity_id = event_data.get('entity_id') + action = event_data.get('action') + source = event_data.get('source') if not entity_id: ctx.logger.error("Keine entity_id im Event gefunden")