Fix admin API, orchestrator, and conversation retrieval bugs

- admin.py: Use ContentSettings object for blob upload content_type
- admin.py: Add required 'description' field mapping for Product model
- orchestrator.py: Update HandoffBuilder to use .participants([...]) method
- orchestrator.py: Pass agent instances instead of strings to set_coordinator/add_handoff
- cosmos_service.py: Add cross-partition query fallback in get_conversation
- cosmos_service.py: Add fallback logic to find correct partition key in delete_conversation

Author: hunterjam

content-gen/src/backend/api/admin.py

@@ -18,6 +18,7 @@
 from typing import Any, Dict, List, Optional
 
 from quart import Blueprint, request, jsonify
+from azure.storage.blob import ContentSettings
 
 from backend.settings import app_settings
 from backend.services.cosmos_service import get_cosmos_service
@@ -129,7 +130,7 @@ async def upload_images():
                 await blob_client.upload_blob(
                     image_data,
                     overwrite=True,
-                    content_settings={"content_type": content_type}
+                    content_settings=ContentSettings(content_type=content_type)
                 )
 
                 results.append({
@@ -233,12 +234,15 @@ async def load_sample_data():
 
             try:
                 # Map incoming fields to Product model fields
+                # Note: Product model requires 'description' field, map from incoming 'description' or 'marketing_description'
+                description_value = product_data.get("description", product_data.get("marketing_description", ""))
                 product_fields = {
                     "product_name": product_data.get("product_name", ""),
                     "sku": product_data.get("sku", ""),
+                    "description": description_value,  # Required field
                     "category": product_data.get("category", ""),
                     "sub_category": product_data.get("sub_category", ""),
-                    "marketing_description": product_data.get("description", product_data.get("marketing_description", "")),
+                    "marketing_description": description_value,  # Also set for backward compat
                     "detailed_spec_description": product_data.get("detailed_spec_description", ""),
                     "image_url": product_data.get("image_url", ""),
                     "image_description": product_data.get("image_description", ""),

content-gen/src/backend/orchestrator.py

@@ -298,32 +298,32 @@ def initialize(self) -> None:
         self._workflow = (
             HandoffBuilder(
                 name="content_generation_workflow",
-                participants=[
-                    triage_agent,
-                    planning_agent,
-                    research_agent,
-                    text_content_agent,
-                    image_content_agent,
-                    compliance_agent,
-                ],
             )
-            .set_coordinator("triage_agent")
+            .participants([
+                triage_agent,
+                planning_agent,
+                research_agent,
+                text_content_agent,
+                image_content_agent,
+                compliance_agent,
+            ])
+            .set_coordinator(triage_agent)
             # Triage can hand off to all specialists
-            .add_handoff("triage_agent", [
-                "planning_agent", 
-                "research_agent", 
-                "text_content_agent", 
-                "image_content_agent", 
-                "compliance_agent"
+            .add_handoff(triage_agent, [
+                planning_agent, 
+                research_agent, 
+                text_content_agent, 
+                image_content_agent, 
+                compliance_agent
             ])
             # All specialists can hand back to triage
-            .add_handoff("planning_agent", ["triage_agent"])
-            .add_handoff("research_agent", ["triage_agent"])
+            .add_handoff(planning_agent, [triage_agent])
+            .add_handoff(research_agent, [triage_agent])
             # Content agents can request compliance check
-            .add_handoff("text_content_agent", ["compliance_agent", "triage_agent"])
-            .add_handoff("image_content_agent", ["compliance_agent", "triage_agent"])
+            .add_handoff(text_content_agent, [compliance_agent, triage_agent])
+            .add_handoff(image_content_agent, [compliance_agent, triage_agent])
             # Compliance can hand back to content agents for corrections or to triage
-            .add_handoff("compliance_agent", ["text_content_agent", "image_content_agent", "triage_agent"])
+            .add_handoff(compliance_agent, [text_content_agent, image_content_agent, triage_agent])
             .with_termination_condition(
                 # Terminate after 10 user messages to prevent infinite loops
                 lambda conv: sum(1 for msg in conv if msg.role.value == "user") >= 10

content-gen/src/backend/services/cosmos_service.py

@@ -279,21 +279,39 @@ async def get_conversation(
         
         Args:
             conversation_id: Unique conversation identifier
-            user_id: User ID for partition key
+            user_id: User ID for partition key (may not match if conversation was created by different user)
         
         Returns:
             Conversation data if found
         """
         await self.initialize()
 
         try:
+            # First try direct read with provided user_id (fast path)
             item = await self._conversations_container.read_item(
                 item=conversation_id,
                 partition_key=user_id
             )
             return item
         except Exception:
-            return None
+            pass
+        
+        # Fallback: cross-partition query to find conversation by ID
+        # This handles cases where the conversation was created with a different user_id
+        try:
+            query = "SELECT * FROM c WHERE c.id = @id"
+            params = [{"name": "@id", "value": conversation_id}]
+            
+            async for item in self._conversations_container.query_items(
+                query=query,
+                parameters=params,
+                max_item_count=1
+            ):
+                return item
+        except Exception:
+            pass
+        
+        return None
 
     async def save_conversation(
         self,
@@ -499,14 +517,30 @@ async def delete_conversation(
         await self.initialize()
 
         try:
+            # First try to delete with provided user_id
             await self._conversations_container.delete_item(
                 item=conversation_id,
                 partition_key=user_id
             )
             return True
+        except Exception:
+            pass
+        
+        # Fallback: find the conversation first to get the correct partition key
+        try:
+            conversation = await self.get_conversation(conversation_id, user_id)
+            if conversation:
+                actual_user_id = conversation.get("user_id", "")
+                await self._conversations_container.delete_item(
+                    item=conversation_id,
+                    partition_key=actual_user_id
+                )
+                return True
         except Exception as e:
             logger.warning(f"Failed to delete conversation {conversation_id}: {e}")
             raise
+        
+        return False
 
 
 # Singleton instance