diff --git a/bitbylaw/steps/vmh/beteiligte_sync_cron_step.py b/bitbylaw/steps/vmh/beteiligte_sync_cron_step.py index db66fc95..71a54ef3 100644 --- a/bitbylaw/steps/vmh/beteiligte_sync_cron_step.py +++ b/bitbylaw/steps/vmh/beteiligte_sync_cron_step.py @@ -114,7 +114,7 @@ async def handler(context): failed_count = sum(1 for r in results if isinstance(r, Exception)) if failed_count > 0: - context.logger.warning(f"⚠️ {failed_count} Events konnten nicht emittiert werden") + context.logger.warn(f"⚠️ {failed_count} Events konnten nicht emittiert werden") # Log first few errors for i, result in enumerate(results[:5]): # Log max 5 errors if isinstance(result, Exception): diff --git a/bitbylaw/steps/vmh/beteiligte_sync_event_step.py b/bitbylaw/steps/vmh/beteiligte_sync_event_step.py index 92b1952f..b5351509 100644 --- a/bitbylaw/steps/vmh/beteiligte_sync_event_step.py +++ b/bitbylaw/steps/vmh/beteiligte_sync_event_step.py @@ -59,7 +59,7 @@ async def handler(event_data, context): lock_acquired = await sync_utils.acquire_sync_lock(entity_id) if not lock_acquired: - context.logger.warning(f"⏸️ Sync bereits aktiv für {entity_id}, überspringe") + context.logger.warn(f"⏸️ Sync bereits aktiv für {entity_id}, überspringe") return # 2. FETCH ENTITY VON ESPOCRM @@ -89,11 +89,11 @@ async def handler(event_data, context): # FALL C: DELETE (TODO: Implementierung später) elif action == 'delete': - context.logger.warning(f"🗑️ DELETE noch nicht implementiert für {entity_id}") + context.logger.warn(f"🗑️ DELETE noch nicht implementiert für {entity_id}") await sync_utils.release_sync_lock(entity_id, 'failed', 'Delete-Operation nicht implementiert') else: - context.logger.warning(f"⚠️ Unbekannte Kombination: action={action}, betnr={betnr}") + context.logger.warn(f"⚠️ Unbekannte Kombination: action={action}, betnr={betnr}") await sync_utils.release_sync_lock(entity_id, 'failed', f'Unbekannte Aktion: {action}') except Exception as e: @@ -176,7 +176,7 @@ async def handle_update(entity_id, betnr, espo_entity, espocrm, advoware, sync_u except Exception as e: # 404 oder anderer Fehler → Beteiligter wurde in Advoware gelöscht if '404' in str(e) or 'nicht gefunden' in str(e).lower(): - context.logger.warning(f"🗑️ Beteiligter in Advoware gelöscht: betNr={betnr}") + context.logger.warn(f"🗑️ Beteiligter in Advoware gelöscht: betNr={betnr}") await sync_utils.handle_advoware_deleted(entity_id, str(e)) return else: @@ -244,7 +244,7 @@ async def handle_update(entity_id, betnr, espo_entity, espocrm, advoware, sync_u # KONFLIKT → EspoCRM WINS elif comparison == 'conflict': - context.logger.warning(f"⚠️ KONFLIKT erkannt → EspoCRM WINS (STAMMDATEN)") + context.logger.warn(f"⚠️ KONFLIKT erkannt → EspoCRM WINS (STAMMDATEN)") # OPTIMIERT: Use merge utility merged_data = sync_utils.merge_for_advoware_put(advo_entity, espo_entity, mapper)