From fcb288c03193443fa212862675589f0103040c9f Mon Sep 17 00:00:00 2001 From: GareArc Date: Thu, 15 Jan 2026 15:14:53 -0800 Subject: [PATCH] feat: add task type --- api/services/enterprise/workspace_sync.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/api/services/enterprise/workspace_sync.py b/api/services/enterprise/workspace_sync.py index acfe325397..4a8f7b07ec 100644 --- a/api/services/enterprise/workspace_sync.py +++ b/api/services/enterprise/workspace_sync.py @@ -12,6 +12,8 @@ logger = logging.getLogger(__name__) WORKSPACE_SYNC_QUEUE = "enterprise:workspace:sync:queue" WORKSPACE_SYNC_PROCESSING = "enterprise:workspace:sync:processing" +TASK_TYPE_SYNC_TO_WORKSPACE = "sync_to_workspace" + class WorkspaceSyncService: """Service to publish workspace sync tasks to Redis queue for enterprise backend consumption""" @@ -38,6 +40,7 @@ class WorkspaceSyncService: "retry_count": 0, "created_at": datetime.now(UTC).isoformat(), "source": source, + "type": TASK_TYPE_SYNC_TO_WORKSPACE, } # Push to Redis list (queue) - LPUSH adds to the head, worker consumes from tail with RPOP