Merge branch 'feature/error-analyzer-8' into 'develop'

Error Analyzer Configuration Update

See merge request genaiic-reusable-assets/engagement-artifacts/genaiic-idp-accelerator!385

Author: webarch-ai

lib/idp_common_pkg/idp_common/config/models.py

@@ -302,13 +302,36 @@ def parse_max_workers(cls, v: Any) -> int:
         return int(v)
 
 
+class ErrorAnalyzerParameters(BaseModel):
+    """Error analyzer parameters configuration"""
+
+    max_log_events: int = Field(default=5, gt=0, description="Maximum number of log events to retrieve")
+    time_range_hours_default: int = Field(default=24, gt=0, description="Default time range in hours for log searches")
+
+    @field_validator("max_log_events", "time_range_hours_default", mode="before")
+    @classmethod
+    def parse_int(cls, v: Any) -> int:
+        """Parse int from string or number"""
+        if isinstance(v, str):
+            return int(v) if v else 0
+        return int(v)
+
+
 class ErrorAnalyzerConfig(BaseModel):
     """Error analyzer agent configuration"""
 
     model_id: str = Field(
         default="us.anthropic.claude-sonnet-4-20250514-v1:0",
         description="Bedrock model ID for error analyzer",
     )
+    system_prompt: str = Field(
+        default="",
+        description="System prompt for error analyzer"
+    )
+    parameters: ErrorAnalyzerParameters = Field(
+        default_factory=ErrorAnalyzerParameters,
+        description="Error analyzer parameters"
+    )
 
 
 class AgentsConfig(BaseModel):

lib/idp_common_pkg/pyproject.toml

@@ -104,7 +104,7 @@ agents = [
 # This includes all dependencies needed for both backends
 docs_service = [
   "requests==2.32.4", # Required for appsync module (dynamodb only needs boto3 which is core)
-  "aws-xray-sdk>=2.12.0", # Required for X-Ray tracing
+  "aws-xray-sdk>=2.14.0", # Required for X-Ray tracing
 ]
 
 # Testing dependencies

lib/idp_common_pkg/setup.py

@@ -61,7 +61,7 @@
     # Document service factory dependencies (includes both appsync and dynamodb support)
     "docs_service": [
         "requests==2.32.4",
-        "aws-xray-sdk>=2.12.0",
+        "aws-xray-sdk>=2.14.0",
     ],
     # Testing dependencies
     "test": [

src/lambda/queue_processor/index.py

@@ -142,8 +142,9 @@ def process_message(record: Dict[str, Any]) -> Tuple[bool, str]:
         object_key = document.input_key
         logger.info(f"Processing message {message_id} for object {object_key}")
 
-        # Add X-Ray annotations and capture trace_id early
-        xray_recorder.put_annotation('document_id', document.id)
+        # X-Ray annotations
+        xray_recorder.put_annotation('document_id', {document.id})
+        xray_recorder.put_annotation('processing_stage', 'queue_processor')
         current_segment = xray_recorder.current_segment()
         if current_segment:
             document.trace_id = current_segment.trace_id