Fix CrewAI compatibility and agent input parameter extraction

services/agents/base_agent.py

@@ -147,13 +147,26 @@ class BaseUtilityAgent(ABC):
         start_time = datetime.now(timezone.utc)
         
         try:
+            # Handle task message structure from MasterOrchestrator
+            # Task messages have structure: {"description": "...", "input": {...}}
+            # We need to extract the actual input for the utility
+            if "input" in input_data and "description" in input_data:
+                # This is a task message from MasterOrchestrator
+                actual_input = input_data["input"]
+                task_description = input_data["description"]
+            else:
+                # Direct call (backward compatibility)
+                actual_input = input_data
+                task_description = None
+            
             # Step 1: Call the original utility function
             # This ensures backward compatibility and correctness
-            utility_result = self.utility_function(input_data)
+            utility_result = self.utility_function(actual_input)
             
             # Step 2: Create a CrewAI task for the agent to validate/enhance the result
             # The agent doesn't replace the utility - it adds intelligence on top
-            task_description = self._prepare_task_description(input_data)
+            if not task_description:
+                task_description = self._prepare_task_description(actual_input)
             
             task = Task(
                 description=task_description,
@@ -186,7 +199,7 @@ class BaseUtilityAgent(ABC):
             }
             
             # Step 5: Log execution
-            self._log_execution(input_data, result, execution_time, True)
+            self._log_execution(actual_input, result, execution_time, True)
             
             return result