Debug your workflows

import { client, executionsList, executionActivitiesGet } from 'asteroid-odyssey';

client.setConfig({
  baseUrl: 'https://odyssey.asteroid.ai/agents/v2',
  headers: { 'X-Asteroid-Agents-Api-Key': process.env.ASTEROID_API_KEY! },
});

const { data: executions } = await executionsList({
  query: { agentId: process.env.ASTEROID_AGENT_ID!, status: ['failed'], pageSize: 1 },
});

const failed = executions?.items ?? [];
if (failed.length === 0) throw new Error('No failed executions to inspect.');

const executionId = failed[0].id;

const { data: activities } = await executionActivitiesGet({
  path: { executionId },
  query: { order: 'asc' },
});

let node = 'start';
for (const activity of activities ?? []) {
  const payload = activity.payload;
  if (payload.activityType === 'transitioned_node') node = payload.newNodeName;
  if (payload.activityType === 'reasoning') console.log(`[${node}] ${payload.reasoning}`);
  if (payload.activityType === 'action_failed') console.log(`[${node}] FAILED ${payload.message}`);
}

import os

from asteroid_odyssey import ApiClient, Configuration
from asteroid_odyssey.api.execution_api import ExecutionApi

config = Configuration(api_key={"ApiKeyAuth": os.environ["ASTEROID_API_KEY"]})

with ApiClient(config) as api_client:
    execution_api = ExecutionApi(api_client)

    executions = execution_api.executions_list(
        agent_id=os.environ["ASTEROID_AGENT_ID"],
        status=["failed"],
        page_size=1,
    )
    if not executions.items:
        raise SystemExit("No failed executions to inspect.")

    execution_id = executions.items[0].id

    activities = execution_api.execution_activities_get(
        execution_id=execution_id,
        order="asc",
    )

    node = "start"
    for activity in activities:
        # payload is a union, so read the resolved model off actual_instance
        payload = activity.payload.actual_instance
        if payload.activity_type == "transitioned_node":
            node = payload.new_node_name
        elif payload.activity_type == "reasoning":
            print(f"[{node}] {payload.reasoning}")
        elif payload.activity_type == "action_failed":
            print(f"[{node}] FAILED {payload.message}")