bsiggel/motia-iii
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: move deferred inline imports (traceback, datetime, pytz) to module top-level in beteiligte and bankverbindungen sync steps

Browse Source
This commit is contained in:
bsiggel
2026-03-31 07:13:45 +00:00
parent 00e95b7526
commit 96c1588a87
2 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/steps/crm/bankverbindungen/bankverbindungen_sync_event_step.py
View File

@@ -18,6 +18,7 @@ from services.bankverbindungen_mapper import BankverbindungenMapper
from services.notification_utils import NotificationManager from services.notification_utils import NotificationManager
from services.redis_client import get_redis_client from services.redis_client import get_redis_client
import json import json
import traceback
config = { config = {
"name": "VMH Bankverbindungen Sync Handler", "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: except Exception as e:
ctx.logger.error(f"❌ Unerwarteter Fehler im Sync-Handler: {e}") ctx.logger.error(f"❌ Unerwarteter Fehler im Sync-Handler: {e}")
import traceback
ctx.logger.error(traceback.format_exc()) ctx.logger.error(traceback.format_exc())
raise raise
@@ -204,7 +204,6 @@ async def handle_update(entity_id, betnr, advoware_id, espo_entity, espocrm, not
except Exception as e: except Exception as e:
ctx.logger.error(f"❌ UPDATE Notification fehlgeschlagen: {e}") ctx.logger.error(f"❌ UPDATE Notification fehlgeschlagen: {e}")
import traceback
ctx.logger.error(traceback.format_exc()) ctx.logger.error(traceback.format_exc())
redis_client.delete(lock_key) redis_client.delete(lock_key)

8
src/steps/crm/beteiligte/beteiligte_sync_event_step.py
View File

@@ -26,6 +26,9 @@ from services.exceptions import (
is_retryable is_retryable
) )
import json import json
import datetime
import traceback
import pytz
config = { config = {
"name": "VMH Beteiligte Sync Handler", "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 # Check Retry-Backoff - überspringe wenn syncNextRetry noch nicht erreicht
sync_next_retry = espo_entity.get('syncNextRetry') sync_next_retry = espo_entity.get('syncNextRetry')
if sync_next_retry and sync_status == 'failed': if sync_next_retry and sync_status == 'failed':
import datetime
import pytz
try: try:
next_retry_ts = datetime.datetime.strptime(sync_next_retry, '%Y-%m-%d %H:%M:%S') 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: except Exception as e:
# Unerwarteter Fehler während Sync - Lock-Release via finally # Unerwarteter Fehler während Sync - Lock-Release via finally
ctx.logger.error(f"❌ Unerwarteter Fehler im Sync-Handler: {e}") ctx.logger.error(f"❌ Unerwarteter Fehler im Sync-Handler: {e}")
import traceback
ctx.logger.error(traceback.format_exc()) ctx.logger.error(traceback.format_exc())
try: try:
@@ -169,7 +169,6 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None:
except Exception as e: except Exception as e:
# Fehler VOR Lock-Acquire - kein Lock-Release nötig # Fehler VOR Lock-Acquire - kein Lock-Release nötig
ctx.logger.error(f"❌ Fehler vor Lock-Acquire: {e}") ctx.logger.error(f"❌ Fehler vor Lock-Acquire: {e}")
import traceback
ctx.logger.error(traceback.format_exc()) 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: except Exception as e:
ctx.logger.error(f"❌ UPDATE fehlgeschlagen: {e}") ctx.logger.error(f"❌ UPDATE fehlgeschlagen: {e}")
import traceback
ctx.logger.error(traceback.format_exc()) ctx.logger.error(traceback.format_exc())
await sync_utils.release_sync_lock(entity_id, 'failed', str(e), increment_retry=True) await sync_utils.release_sync_lock(entity_id, 'failed', str(e), increment_retry=True)