fix: update AZURE_OPENAI_API_VERSION to 2025-03-01-preview and apply lint fixes

- Update AZURE_OPENAI_API_VERSION from 2025-01-01-preview to 2025-03-01-preview in both main.bicep and main_custom.bicep

- Fix ruff lint errors in backend-api (None comparison, unused variables)

- Apply ruff formatting across processor and backend-api source files

Author: Dongbumlee

infra/main.bicep

@@ -899,7 +899,7 @@ module appConfiguration 'br/public:avm/res/app-configuration/configuration-store
       }
       {
         name: 'AZURE_OPENAI_API_VERSION'
-        value: '2025-01-01-preview'
+        value: '2025-03-01-preview'
       }
       {
         name: 'AZURE_OPENAI_CHAT_DEPLOYMENT_NAME'

infra/main_custom.bicep

@@ -877,7 +877,7 @@ module appConfiguration 'br/public:avm/res/app-configuration/configuration-store
       }
       {
         name: 'AZURE_OPENAI_API_VERSION'
-        value: '2025-01-01-preview'
+        value: '2025-03-01-preview'
       }
       {
         name: 'AZURE_OPENAI_CHAT_DEPLOYMENT_NAME'

src/backend-api/src/app/libs/application/application_configuration.py

@@ -34,8 +34,12 @@ class Configuration(_configuration_base, KernelBaseSettings):
     app_sample_variable: str = Field(default="Hello World!")
 
     # Azure logging configuration
-    azure_package_logging_level: str = Field(default="WARNING", alias="AZURE_PACKAGE_LOGGING_LEVEL")
-    azure_logging_packages: str | None = Field(default=None, alias="AZURE_LOGGING_PACKAGES")
+    azure_package_logging_level: str = Field(
+        default="WARNING", alias="AZURE_PACKAGE_LOGGING_LEVEL"
+    )
+    azure_logging_packages: str | None = Field(
+        default=None, alias="AZURE_LOGGING_PACKAGES"
+    )
 
     global_llm_service: str | None = "AzureOpenAI"
     cosmos_db_process_log_container: str | None = Field(

src/backend-api/src/app/libs/base/application_base.py

@@ -62,8 +62,20 @@ def __init__(self, env_file_path: str | None = None, **data):
 
             # Configure Azure package logging levels only if packages are specified
             if self.application_context.configuration.azure_logging_packages:
-                azure_level = getattr(logging, self.application_context.configuration.azure_package_logging_level.upper(), logging.WARNING)
-                for logger_name in filter(None, (pkg.strip() for pkg in self.application_context.configuration.azure_logging_packages.split(','))):
+                azure_level = getattr(
+                    logging,
+                    self.application_context.configuration.azure_package_logging_level.upper(),
+                    logging.WARNING,
+                )
+                for logger_name in filter(
+                    None,
+                    (
+                        pkg.strip()
+                        for pkg in self.application_context.configuration.azure_logging_packages.split(
+                            ","
+                        )
+                    ),
+                ):
                     logging.getLogger(logger_name).setLevel(azure_level)
 
         # Initialize the application

src/backend-api/src/app/libs/base/fastapi_protocol.py

@@ -16,8 +16,7 @@ class FastAPIWithContext(Protocol):
     app_context: AppContext
 
     # Include essential FastAPI methods for type checking
-    def include_router(self, *args, **kwargs) -> None:
-        ...
+    def include_router(self, *args, **kwargs) -> None: ...
 
 
 def add_app_context_to_fastapi(

src/backend-api/src/app/libs/repositories/process_status_repository.py

@@ -1,15 +1,13 @@
 import asyncio
+from datetime import UTC, datetime
 from typing import Any
 
-from sas.cosmosdb.sql.repository import RepositoryBase
-
 from routers.models.process_agent_activities import (
     AgentStatus,
     ProcessStatus,
     ProcessStatusSnapshot,
 )
-
-from datetime import datetime, UTC
+from sas.cosmosdb.sql.repository import RepositoryBase
 
 
 def calculate_activity_duration(activity_start: str) -> tuple[int, str]:
@@ -142,7 +140,7 @@ async def get_process_status_by_process_id(
             )
 
             status = await self.get_async(process_id)
-            if status != None:
+            if status is not None:
                 return ProcessStatusSnapshot(
                     process_id=status.id,  # Fix: use process_id instead of id
                     step=status.step,
@@ -305,26 +303,7 @@ async def render_agent_status(self, process_id: str) -> dict:
             formatted_lines = []
             agent_metrics = {}
 
-            # Check if process failed early (before agents really started working)
             process_failed = getattr(process_data, "status", "") == "failed"
-            process_duration_seconds = 0
-            if hasattr(process_data, "started_at_time") and hasattr(
-                process_data, "last_update_time"
-            ):
-                try:
-                    start = datetime.fromisoformat(
-                        process_data.started_at_time.replace(" UTC", "+00:00")
-                    )
-                    end = datetime.fromisoformat(
-                        process_data.last_update_time.replace(" UTC", "+00:00")
-                    )
-                    process_duration_seconds = int((end - start).total_seconds())
-                except Exception:
-                    pass
-
-            early_failure = (
-                process_failed and process_duration_seconds < 30
-            )  # Failed in less than 30 seconds
 
             # Analyze each agent with enhanced insights
             for agent_name, agent_data in agents_data.items():
@@ -413,6 +392,23 @@ async def render_agent_status(self, process_id: str) -> dict:
                 if is_active and duration_seconds > 30:
                     message_parts.append(f"({duration_str})")
 
+                # Add tool usage from recent activity history
+                recent_tools = []
+                for h in activity_history[-5:]:
+                    tool = h.get("tool_used", "")
+                    if tool and tool not in recent_tools:
+                        recent_tools.append(tool)
+                if recent_tools:
+                    tool_names = ", ".join(
+                        recent_tools[-3:]
+                    )  # Show last 3 unique tools
+                    message_parts.append(f"🔧 {tool_names}")
+
+                # Add activity count
+                total_activities = len(activity_history)
+                if total_activities > 0:
+                    message_parts.append(f"📊 {total_activities} actions")
+
                 # Add relationship indicators
                 if relationships["waiting_for"]:
                     waiting_names = [
@@ -496,6 +492,25 @@ async def render_agent_status(self, process_id: str) -> dict:
                 "bottleneck_score": total_blocking,
                 "fast_agents": fast_agents,
                 "failed_agents": failed_agents,
+                # NEW: Structured agent activities for rich frontend display
+                "agent_activities": agents_data,
+                # NEW: Step timing data
+                "step_timings": {
+                    k: v
+                    for k, v in (
+                        getattr(process_data, "step_timings", {}) or {}
+                    ).items()
+                },
+                # NEW: Step results and metrics
+                "step_results": {
+                    k: v
+                    for k, v in (
+                        getattr(process_data, "step_results", {}) or {}
+                    ).items()
+                },
+                "generated_files": getattr(process_data, "generated_files", []) or [],
+                "conversion_metrics": getattr(process_data, "conversion_metrics", {})
+                or {},
             }
 
     async def render_agent_status_old(self, process_id: str) -> dict:

src/backend-api/src/app/libs/services/interfaces.py

@@ -2,7 +2,7 @@
 # Licensed under the MIT License.
 
 from abc import ABC, abstractmethod
-from typing import Any, Dict, Union
+from typing import Any, Dict
 
 
 class IDataService(ABC):

src/backend-api/src/app/routers/models/files.py

@@ -1,4 +1,3 @@
-from datetime import datetime, timezone
 from pydantic import BaseModel, Field
 
 

src/backend-api/src/app/routers/router_files.py

@@ -13,17 +13,14 @@
 )
 from fastapi.responses import Response
 from libs.base.typed_fastapi import TypedFastAPI
-from libs.models.entities import File, Process
+from libs.models.entities import File
 from libs.sas.storage import AsyncStorageBlobHelper
 from libs.services.auth import get_authenticated_user
 from libs.services.input_validation import is_valid_uuid
 from libs.services.interfaces import ILoggerService
-from libs.sas.storage import AsyncStorageBlobHelper
-from libs.models.entities import File, Process
 from routers.models.files import FileUploadResult
 from libs.repositories.process_repository import ProcessRepository
 from libs.repositories.file_repository import FileRepository
-from libs.repositories.process_repository import ProcessRepository
 
 router = APIRouter(
     prefix="/api/file",

src/processor/.devcontainer/devcontainer.json

@@ -42,7 +42,7 @@
         "UV_PROJECT_ENVIRONMENT": "/home/vscode/.venv",
         "VIRTUAL_ENV": "/home/vscode/.venv"
     },
-    "postCreateCommand": "uv sync --python 3.12 --prerelease=allow --link-mode=copy --frozen",
+    "postCreateCommand": "uv sync --python 3.12 --link-mode=copy --frozen",
     "postStartCommand": "uv tool install pre-commit --with pre-commit-uv --force-reinstall",
     "remoteUser": "vscode"
 }