Fix app workflows list (#458)

Author: rholinshead

src/mcp_agent/cli/cloud/commands/app/workflows/main.py

@@ -5,11 +5,9 @@
 
 import typer
 from rich.console import Group
-from rich.padding import Padding
 from rich.panel import Panel
 from rich.prompt import Prompt
 from rich.syntax import Syntax
-from rich.table import Table
 from rich.text import Text
 
 from mcp_agent.cli.auth import load_api_key_credentials
@@ -248,16 +246,12 @@ def get_start_time(run: WorkflowRun):
             reverse=True,
         )
 
-        table = Table(title="Workflow Runs", show_lines=False, border_style="blue")
-        table.add_column("Name", style="white", overflow="fold")
-        table.add_column("Workflow ID", style="bold cyan", no_wrap=True)
-        table.add_column("Run ID", style="blue", overflow="fold")
-        table.add_column("Status", overflow="fold")
-        table.add_column("Start Time", style="magenta", overflow="fold")
-        table.add_column("End Time", style="yellow", overflow="fold")
+        console.print(f"\n[bold blue] Workflow Runs ({len(sorted_runs)})[/bold blue]")
+
+        for i, run in enumerate(sorted_runs):
+            if i > 0:
+                console.print()
 
-        for idx, run in enumerate(sorted_runs):
-            is_last_row = idx == len(sorted_runs) - 1
             start = getattr(run.temporal, "start_time", None)
             start_str = (
                 datetime.fromtimestamp(start).strftime("%Y-%m-%d %H:%M:%S")
@@ -274,22 +268,31 @@ def get_start_time(run: WorkflowRun):
 
             status = run.status.lower()
             if status == "completed":
-                status_text = f"[green]{status}[/green]"
-            elif status == "error":
-                status_text = f"[red]{status}[/red]"
+                status_text = f"[green]🟢 {status}[/green]"
+            elif status == "error" or status == "failed":
+                status_text = f"[red]🔴 {status}[/red]"
+            elif status == "running":
+                status_text = f"[yellow]🔄 {status}[/yellow]"
             else:
-                status_text = status
-
-            table.add_row(
-                run.name or "-",
-                run.temporal.workflow_id if run.temporal else "N/A",
-                Padding(run.id, (0, 0, 0 if is_last_row else 1, 0)),
-                status_text,
-                start_str,
-                end_str,
+                status_text = f"❓ {status}"
+
+            console.print(
+                f"[bold cyan]{run.name or 'Unnamed Workflow'}[/bold cyan] {status_text}"
             )
+            console.print(f"  Run ID: {run.id}")
+
+            if run.temporal and run.temporal.workflow_id:
+                console.print(f"  Workflow ID: {run.temporal.workflow_id}")
+
+            console.print(f"  Started: {start_str}")
+            if end_str != "N/A":
+                console.print(f"  Completed: {end_str}")
 
-        console.print(table)
+            # Show execution time if available
+            if hasattr(run.temporal, "execution_time") and run.temporal.execution_time:
+                duration = end - start if (start and end) else None
+                if duration:
+                    console.print(f"  Duration: {duration:.2f}s")
 
     except Exception as e:
         print_error(f"Error fetching workflow runs: {str(e)}")

src/mcp_agent/cli/mcp_app/mcp_client.py

@@ -1,3 +1,4 @@
+import ast
 import asyncio
 import json
 from contextlib import asynccontextmanager
@@ -62,10 +63,13 @@ class WorkflowRunState(BaseModel):
 class WorkflowRunResult(BaseModel):
     """The result of a workflow run."""
 
+    kind: str
+    """The kind/type of result returned by the workflow run."""
+
     value: str
     """The value returned by the workflow run, if any."""
 
-    metadata: dict
+    metadata: Optional[dict[str, Any]] = None
     """Metadata associated with the workflow run result."""
 
     start_time: Optional[float] = None
@@ -99,6 +103,9 @@ class WorkflowRunTemporal(BaseModel):
     close_time: Optional[float] = None
     """The time when the workflow run completed."""
 
+    execution_time: Optional[float] = None
+    """The total time taken for the workflow run."""
+
 
 class WorkflowRun(BaseModel):
     """An execution instance of a workflow definition."""
@@ -187,9 +194,20 @@ async def list_workflow_runs(self) -> ListWorkflowRunsResult:
                 # Assuming the content is a JSON string representing a WorkflowRun item dict
                 try:
                     run_data = json.loads(item.text)
+                    if "result" in run_data and isinstance(run_data["result"], str):
+                        try:
+                            # Could be stringified python dict instead of valid JSON
+                            run_data["result"] = ast.literal_eval(run_data["result"])
+                        except (ValueError, SyntaxError) as e:
+                            try:
+                                run_data["result"] = json.loads(run_data["result"])
+                            except json.JSONDecodeError:
+                                raise ValueError(
+                                    f"Invalid workflow run result data: {e}"
+                                ) from e
                     runs.append(WorkflowRun(**run_data))
                 except json.JSONDecodeError as e:
-                    raise ValueError(f"Invalid workflow run data: {e}")
+                    raise ValueError(f"Invalid workflow run data: {e}") from e
 
         return ListWorkflowRunsResult(workflow_runs=runs)