Events

import { runWorkflow } from "smthrs";
import { Effect } from "effect";
import workflow from "./workflow";

await Effect.runPromise(runWorkflow(workflow, {
  input: { task: "fix bug" },
  onProgress: (event) => {
    if (event.type === "NodeStarted")  console.log(`▶ ${event.nodeId} (attempt ${event.attempt})`);
    if (event.type === "NodeFinished") console.log(`✓ ${event.nodeId}`);
    if (event.type === "NodeFailed")   console.error(`✗ ${event.nodeId}`, event.error);
  },
}));

tail -f .smithers/executions/<runId>/logs/stream.ndjson | jq .
jq 'select(.type == "NodeFailed")' .smithers/executions/<runId>/logs/stream.ndjson
jq -r .type .smithers/executions/<runId>/logs/stream.ndjson | sort | uniq -c | sort -rn

bunx smthrs events RUN_ID --json
bunx smthrs events RUN_ID --type tool-call --node analyze

type CommonFields    = { type: string; runId: string; timestampMs: number };
type NodeScoped      = CommonFields & { nodeId: string; iteration: number };
type AttemptScoped   = NodeScoped   & { attempt: number };

{
  type: "TokenUsageReported",
  nodeId, iteration, attempt, model, agent,
  inputTokens,       // provider-reported input counter
  freshInputTokens,  // non-cached input
  cacheReadTokens,   // input breakdown; do not add to inputTokens
  cacheWriteTokens,  // input breakdown; do not add to inputTokens
  outputTokens,      // total provider output
  reasoningTokens,   // output breakdown; do not add to outputTokens
  costUsd,           // optional estimate from Smithers' model price table
}