Develop

backend/alembic/versions/015_add_verdict_trace_provenance_fingerprint.py

@@ -0,0 +1,52 @@
+"""Add verdict, trace_data, provenance, and fingerprint to evaluation_runs.
+
+Revision ID: 015
+Revises: 014
+Create Date: 2026-08-24
+"""
+
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+import sqlalchemy as sa
+
+from alembic import op
+
+if TYPE_CHECKING:
+    from collections.abc import Sequence
+
+
+# revision identifiers
+revision: str = "015"
+down_revision: str | None = "014"
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    """Add verdict, trace_data, provenance, and fingerprint columns."""
+    op.add_column(
+        "evaluation_runs",
+        sa.Column("verdict", sa.String(20), nullable=True),
+    )
+    op.add_column(
+        "evaluation_runs",
+        sa.Column("trace_data", sa.JSON, nullable=True),
+    )
+    op.add_column(
+        "evaluation_runs",
+        sa.Column("provenance", sa.JSON, nullable=True),
+    )
+    op.add_column(
+        "evaluation_runs",
+        sa.Column("fingerprint", sa.String(64), nullable=True),
+    )
+
+
+def downgrade() -> None:
+    """Remove verdict, trace_data, provenance, and fingerprint columns."""
+    op.drop_column("evaluation_runs", "fingerprint")
+    op.drop_column("evaluation_runs", "provenance")
+    op.drop_column("evaluation_runs", "trace_data")
+    op.drop_column("evaluation_runs", "verdict")

backend/alembic/versions/016_create_agent_trajectories_table.py

@@ -0,0 +1,69 @@
+"""Create agent_trajectories table.
+
+Revision ID: 016
+Revises: 015
+Create Date: 2026-08-24
+"""
+
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+import sqlalchemy as sa
+
+from alembic import op
+
+if TYPE_CHECKING:
+    from collections.abc import Sequence
+
+
+# revision identifiers
+revision: str = "016"
+down_revision: str | None = "015"
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    """Create the agent_trajectories table."""
+    op.create_table(
+        "agent_trajectories",
+        sa.Column("id", sa.String(36), primary_key=True),
+        sa.Column("run_id", sa.String(36), nullable=False),
+        sa.Column("agent_name", sa.String(255), nullable=False),
+        sa.Column("status", sa.String(30), nullable=False),
+        sa.Column("total_steps", sa.Integer(), server_default="0", nullable=False),
+        sa.Column("total_llm_calls", sa.Integer(), server_default="0", nullable=False),
+        sa.Column("total_tool_calls", sa.Integer(), server_default="0", nullable=False),
+        sa.Column("total_tokens_input", sa.Integer(), server_default="0", nullable=False),
+        sa.Column("total_tokens_output", sa.Integer(), server_default="0", nullable=False),
+        sa.Column("total_cost_usd", sa.Float(), server_default="0.0", nullable=False),
+        sa.Column("total_duration_ms", sa.Integer(), server_default="0", nullable=False),
+        sa.Column("final_response", sa.Text(), server_default="", nullable=False),
+        sa.Column("conversation_history", sa.JSON(), nullable=False),
+        sa.Column("tool_calls", sa.JSON(), nullable=False),
+        sa.Column("llm_calls", sa.JSON(), nullable=False),
+        sa.Column("error", sa.Text(), nullable=True),
+        sa.Column("metadata", sa.JSON(), nullable=False),
+        sa.Column(
+            "created_at",
+            sa.DateTime(timezone=True),
+            server_default=sa.func.now(),
+            nullable=False,
+        ),
+        sa.Column(
+            "updated_at",
+            sa.DateTime(timezone=True),
+            server_default=sa.func.now(),
+            nullable=False,
+        ),
+    )
+    op.create_index("ix_agent_trajectories_run_id", "agent_trajectories", ["run_id"])
+    op.create_index("ix_agent_trajectories_created_at", "agent_trajectories", ["created_at"])
+
+
+def downgrade() -> None:
+    """Drop the agent_trajectories table."""
+    op.drop_index("ix_agent_trajectories_created_at", table_name="agent_trajectories")
+    op.drop_index("ix_agent_trajectories_run_id", table_name="agent_trajectories")
+    op.drop_table("agent_trajectories")

backend/app/agents/api/router.py

@@ -2,6 +2,7 @@
 
 from __future__ import annotations
 
+from datetime import timedelta
 from typing import TYPE_CHECKING
 
 from fastapi import APIRouter, Depends, HTTPException, Query, Request
@@ -25,7 +26,14 @@
     RetryAgentRunHandler,
 )
 from app.agents.temporal.workflow import AgentRunWorkflow, AgentRunWorkflowInput
-from app.core.dependencies import CurrentUser, get_current_user, get_db_session, get_temporal_client
+from app.core.config import AppConfig
+from app.core.dependencies import (
+    CurrentUser,
+    get_config_dependency,
+    get_current_user,
+    get_db_session,
+    get_temporal_client,
+)
 from app.infrastructure.database.repositories.agent_run_repository import (
     SqlAlchemyAgentRunRepository,
 )
@@ -114,6 +122,7 @@ async def create_agent_run(
     current_user: CurrentUser = Depends(get_current_user),
     session: AsyncSession = Depends(get_db_session),
     temporal_client: TemporalClient = Depends(get_temporal_client),
+    config: AppConfig = Depends(get_config_dependency),
 ) -> AgentRunResponse:
     """Create a new agent run and schedule its execution."""
     repo = _get_repository(session)
@@ -140,10 +149,11 @@ async def create_agent_run(
             AgentRunWorkflow.run,
             AgentRunWorkflowInput(
                 run_id=str(run.id),
-                total_steps=body.max_steps,
+                max_steps=body.max_steps,
             ),
             id=workflow_id,
-            task_queue="redops-agents",
+            task_queue=config.temporal_task_queue,
+            execution_timeout=timedelta(hours=1),
         )
 
         queue_handler = QueueAgentRunHandler(repo)

backend/app/agents/domain/contracts/agent_contracts.py

@@ -129,3 +129,55 @@ async def publish(self, event: object) -> None:
     async def publish_many(self, events: list[object]) -> None:
         """Publish multiple domain events."""
         ...
+
+
+@dataclass
+class TrajectoryQuery:
+    """Query parameters for listing trajectories."""
+
+    run_id: str | None = None
+    agent_name: str | None = None
+    status: str | None = None
+    sort_by: str = "created_at"
+    sort_order: str = "desc"
+    page: int = 1
+    page_size: int = 20
+
+
+@dataclass
+class PaginatedTrajectories:
+    """Paginated result for trajectory listing."""
+
+    items: list[dict[str, object]] = field(default_factory=list)
+    total: int = 0
+    page: int = 1
+    page_size: int = 20
+
+
+class AgentTrajectoryRepository(ABC):
+    """Repository for agent trajectory persistence."""
+
+    @abstractmethod
+    async def save(self, trajectory: dict[str, object]) -> None:
+        """Save a trajectory."""
+        ...
+
+    @abstractmethod
+    async def find_by_id(self, trajectory_id: str) -> dict[str, object] | None:
+        """Find a trajectory by ID."""
+        ...
+
+    @abstractmethod
+    async def find_by_run_id(self, run_id: str) -> dict[str, object] | None:
+        """Find trajectory by run ID."""
+        ...
+
+    @abstractmethod
+    async def list(self, query: TrajectoryQuery) -> PaginatedTrajectories:
+        """List trajectories with filtering and pagination."""
+        ...
+
+    @abstractmethod
+    async def delete(self, trajectory_id: str) -> bool:
+        """Delete a trajectory by ID."""
+        ...