diff --git a/steps/vmh/aiknowledge_sync_event_step.py b/steps/vmh/aiknowledge_sync_event_step.py index 29daca4..26d1afb 100644 --- a/steps/vmh/aiknowledge_sync_event_step.py +++ b/steps/vmh/aiknowledge_sync_event_step.py @@ -55,7 +55,7 @@ async def handler(event_data: Dict[str, Any], ctx: FlowContext[Any]) -> None: lock_acquired = await sync_utils.acquire_sync_lock(knowledge_id) if not lock_acquired: - ctx.logger.warning(f"⏸️ Lock already held for {knowledge_id}, skipping") + ctx.logger.warn(f"⏸️ Lock already held for {knowledge_id}, skipping") ctx.logger.info(" (Will be retried by Motia queue)") raise RuntimeError(f"Lock busy for {knowledge_id}") # Motia will retry