From 96c1588a87481ce75a393a15764906c635b0f41c Mon Sep 17 00:00:00 2001 From: bsiggel Date: Tue, 31 Mar 2026 07:13:45 +0000 Subject: [PATCH] fix: move deferred inline imports (traceback, datetime, pytz) to module top-level in beteiligte and bankverbindungen sync steps --- .../bankverbindungen/bankverbindungen_sync_event_step.py | 3 +-- src/steps/crm/beteiligte/beteiligte_sync_event_step.py | 8 +++----- 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/src/steps/crm/bankverbindungen/bankverbindungen_sync_event_step.py b/src/steps/crm/bankverbindungen/bankverbindungen_sync_event_step.py index cfd297f..32ff227 100644 --- a/src/steps/crm/bankverbindungen/bankverbindungen_sync_event_step.py +++ b/src/steps/crm/bankverbindungen/bankverbindungen_sync_event_step.py @@ -18,6 +18,7 @@ from services.bankverbindungen_mapper import BankverbindungenMapper from services.notification_utils import NotificationManager from services.redis_client import get_redis_client import json +import traceback config = { "name": "VMH Bankverbindungen Sync Handler", @@ -108,7 +109,6 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None: except Exception as e: ctx.logger.error(f"❌ Unerwarteter Fehler im Sync-Handler: {e}") - import traceback ctx.logger.error(traceback.format_exc()) raise @@ -204,7 +204,6 @@ async def handle_update(entity_id, betnr, advoware_id, espo_entity, espocrm, not except Exception as e: ctx.logger.error(f"❌ UPDATE Notification fehlgeschlagen: {e}") - import traceback ctx.logger.error(traceback.format_exc()) redis_client.delete(lock_key) diff --git a/src/steps/crm/beteiligte/beteiligte_sync_event_step.py b/src/steps/crm/beteiligte/beteiligte_sync_event_step.py index bd55ccd..649d941 100644 --- a/src/steps/crm/beteiligte/beteiligte_sync_event_step.py +++ b/src/steps/crm/beteiligte/beteiligte_sync_event_step.py @@ -26,6 +26,9 @@ from services.exceptions import ( is_retryable ) import json +import datetime +import traceback +import pytz config = { "name": "VMH Beteiligte Sync Handler", @@ -104,8 +107,6 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None: # Check Retry-Backoff - überspringe wenn syncNextRetry noch nicht erreicht sync_next_retry = espo_entity.get('syncNextRetry') if sync_next_retry and sync_status == 'failed': - import datetime - import pytz try: next_retry_ts = datetime.datetime.strptime(sync_next_retry, '%Y-%m-%d %H:%M:%S') @@ -144,7 +145,6 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None: except Exception as e: # Unerwarteter Fehler während Sync - Lock-Release via finally ctx.logger.error(f"❌ Unerwarteter Fehler im Sync-Handler: {e}") - import traceback ctx.logger.error(traceback.format_exc()) try: @@ -169,7 +169,6 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None: except Exception as e: # Fehler VOR Lock-Acquire - kein Lock-Release nötig ctx.logger.error(f"❌ Fehler vor Lock-Acquire: {e}") - import traceback ctx.logger.error(traceback.format_exc()) @@ -417,6 +416,5 @@ async def handle_update(entity_id, betnr, espo_entity, espocrm, advoware, sync_u except Exception as e: ctx.logger.error(f"❌ UPDATE fehlgeschlagen: {e}") - import traceback ctx.logger.error(traceback.format_exc()) await sync_utils.release_sync_lock(entity_id, 'failed', str(e), increment_retry=True)