diff --git a/surfsense_backend/alembic/versions/15_add_clickup_connector_enums.py b/surfsense_backend/alembic/versions/15_add_clickup_connector_enums.py
index 8882cfc..4c5a625 100644
--- a/surfsense_backend/alembic/versions/15_add_clickup_connector_enums.py
+++ b/surfsense_backend/alembic/versions/15_add_clickup_connector_enums.py
@@ -1,7 +1,7 @@
 """Add ClickUp connector enums
 
-Revision ID: 15_add_clickup_connector_enums
-Revises: 14_add_confluence_connector_enums
+Revision ID: '15'
+Revises: '14'
 Create Date: 2025-07-29 12:00:00.000000
 
 """
@@ -11,8 +11,8 @@ from collections.abc import Sequence
 from alembic import op
 
 # revision identifiers, used by Alembic.
-revision: str = "15_add_clickup_connector_enums"
-down_revision: str | None = "14_add_confluence_connector_enums"
+revision: str = '15'
+down_revision: str | None = '14'
 branch_labels: str | Sequence[str] | None = None
 depends_on: str | Sequence[str] | None = None
 
diff --git a/surfsense_backend/app/services/connector_service.py b/surfsense_backend/app/services/connector_service.py
index de9c4c2..9389807 100644
--- a/surfsense_backend/app/services/connector_service.py
+++ b/surfsense_backend/app/services/connector_service.py
@@ -1,4 +1,5 @@
 import asyncio
+import json
 from typing import Any
 
 from linkup import LinkupClient
@@ -1222,22 +1223,21 @@ class ConnectorService:
         sources_list = []
 
         for chunk in clickup_chunks:
-            if hasattr(chunk, "metadata") and chunk.metadata:
-                document = chunk.metadata
-            else:
-                # Handle case where chunk is a dict (from document retriever)
-                document = chunk
+            
+            # Extract document metadata
+            document = chunk.get("document", {})
+            metadata = document.get("metadata", {})
 
             # Extract ClickUp task information from metadata
-            task_name = document.get("task_name", "Unknown Task")
-            task_id = document.get("task_id", "")
-            task_url = document.get("task_url", "")
-            task_status = document.get("task_status", "Unknown")
-            task_priority = document.get("task_priority", "Unknown")
-            task_assignees = document.get("task_assignees", [])
-            task_due_date = document.get("task_due_date", "")
-            task_list_name = document.get("task_list_name", "")
-            task_space_name = document.get("task_space_name", "")
+            task_name = metadata.get("task_name", "Unknown Task")
+            task_id = metadata.get("task_id", "")
+            task_url = metadata.get("task_url", "")
+            task_status = metadata.get("task_status", "Unknown")
+            task_priority = metadata.get("task_priority", "Unknown")
+            task_assignees = metadata.get("task_assignees", [])
+            task_due_date = metadata.get("task_due_date", "")
+            task_list_name = metadata.get("task_list_name", "")
+            task_space_name = metadata.get("task_space_name", "")
 
             # Create description from task details
             description_parts = []