From c5299b28898ee4838d3027bd21e685651325b8e8 Mon Sep 17 00:00:00 2001 From: bsiggel Date: Tue, 31 Mar 2026 07:00:59 +0000 Subject: [PATCH] =?UTF-8?q?fix:=20replace=20step=5Flogger=20with=20ctx.log?= =?UTF-8?q?ger=20in=20beteiligte=5Fsync=5Fevent=5Fstep=20=E2=80=93=20use?= =?UTF-8?q?=20consistent=20context-aware=20logging?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../crm/beteiligte/beteiligte_sync_event_step.py | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/src/steps/crm/beteiligte/beteiligte_sync_event_step.py b/src/steps/crm/beteiligte/beteiligte_sync_event_step.py index 977ed8a..bd55ccd 100644 --- a/src/steps/crm/beteiligte/beteiligte_sync_event_step.py +++ b/src/steps/crm/beteiligte/beteiligte_sync_event_step.py @@ -25,7 +25,6 @@ from services.exceptions import ( RetryableError, is_retryable ) -from services.logging_utils import get_step_logger import json config = { @@ -54,17 +53,16 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None: action = event_data.get('action') source = event_data.get('source') - step_logger = get_step_logger('beteiligte_sync', ctx) if not entity_id: - step_logger.error("Keine entity_id im Event gefunden") + ctx.logger.error("Keine entity_id im Event gefunden") return - step_logger.info("=" * 80) - step_logger.info(f"🔄 BETEILIGTE SYNC HANDLER: {action.upper()}") - step_logger.info("=" * 80) - step_logger.info(f"Entity: {entity_id} | Source: {source}") - step_logger.info("=" * 80) + ctx.logger.info("=" * 80) + ctx.logger.info(f"🔄 BETEILIGTE SYNC HANDLER: {action.upper()}") + ctx.logger.info("=" * 80) + ctx.logger.info(f"Entity: {entity_id} | Source: {source}") + ctx.logger.info("=" * 80) # Get shared Redis client (centralized) redis_client = get_redis_client(strict=False)