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)