From 1313826c57beebb3a933116a64c22dcd8343aa66 Mon Sep 17 00:00:00 2001 From: Hamza Rashid Date: Thu, 4 Jun 2026 19:09:51 +0000 Subject: [PATCH] misc: collab event logs --- .../services/collaboration_events/sqlite.py | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/src/backend/base/langflow/services/collaboration_events/sqlite.py b/src/backend/base/langflow/services/collaboration_events/sqlite.py index 0038fef921..a892f5e2aa 100644 --- a/src/backend/base/langflow/services/collaboration_events/sqlite.py +++ b/src/backend/base/langflow/services/collaboration_events/sqlite.py @@ -24,6 +24,8 @@ from langflow.services.collaboration_events.schemas import ( ) from langflow.services.collaboration_events.service import CollaborationEventService +_LOG_PREFIX = "[Collaboration Events (SQLite)] " + _SCHEMA = """ CREATE TABLE IF NOT EXISTS events ( id TEXT NOT NULL, @@ -143,12 +145,20 @@ class SQLiteCollaborationEventService(CollaborationEventService): await self._enforce_per_flow_cap_locked(conn, flow_id_key) await conn.execute("COMMIT") await logger.adebug( - "Published collaboration event %s for flow %s (id: %s)", event_type, flow_id_key, event_id + "%sPublished collaboration event %s for flow %s (event_id: %s)", + _LOG_PREFIX, + event_type, + flow_id_key, + event_id, ) except Exception as exc: await conn.execute("ROLLBACK") await logger.aerror( - "Failed to publish collaboration event %s for flow %s: %s", event_type, flow_id_key, exc + "%sFailed to publish collaboration event %s for flow %s: %s", + _LOG_PREFIX, + event_type, + flow_id_key, + exc, ) raise @@ -223,7 +233,7 @@ class SQLiteCollaborationEventService(CollaborationEventService): conn = await self._ensure_conn() now = time.time() await self._purge_expired_locked(conn, now) - await logger.adebug("Completed collaboration events cleanup") + await logger.adebug("%sCompleted collaboration events cleanup", _LOG_PREFIX) async def add_connection( self,