Query runs

bunx automate.ax login
bunx automate.ax data sync

bunx automate.ax data sync --project proj_01... --since 30d
bunx automate.ax data sync --org org_01... --since 2026-08-01T00:00:00Z
bunx automate.ax data sync --project proj_01... --since all

bunx automate.ax data follow --project proj_01... --since 1h

response=$(curl --fail-with-body --silent --show-error "$TRIGGER_URL")
event_id=$(jq -er '.eventId' <<<"$response")

poll_deadline=$((SECONDS + 300))
while true; do
  result=$(bunx automate.ax query --json --sql "
    WITH RECURSIVE run_contexts(context_id) AS (
      SELECT DISTINCT context_id
      FROM automate.event_links
      WHERE event_id = '$event_id'

      UNION

      SELECT related.context_id
      FROM run_contexts AS current
      CROSS JOIN LATERAL (
        SELECT descendants.descendant_context_id AS context_id
        FROM automate.context_descendants AS descendants
        WHERE descendants.context_id = current.context_id

        UNION

        SELECT delivery_links.context_id
        FROM automate.actions
        INNER JOIN automate.automation_invocations AS invocations
          ON invocations.idempotency_key = actions.id
        INNER JOIN automate.event_links AS delivery_links
          ON delivery_links.event_id = invocations.event_id
        WHERE actions.context_id = current.context_id
          AND starts_with(invocations.entrypoint, '__\$delay:')
      ) AS related
    )
    SELECT true AS complete
    FROM run_contexts
    INNER JOIN automate.contexts AS contexts
      ON contexts.id = run_contexts.context_id
    HAVING count(*) > 0
      AND bool_and(contexts.status IN ('settled', 'failed'))
      AND NOT EXISTS (
        SELECT 1
        FROM automate.actions
        INNER JOIN automate.automation_invocations AS invocations
          ON invocations.idempotency_key = actions.id
        WHERE actions.context_id IN (SELECT context_id FROM run_contexts)
          AND starts_with(invocations.entrypoint, '__\$delay:')
          AND (
            invocations.processed_at IS NULL
            OR (
              invocations.event_id IS NOT NULL
              AND NOT EXISTS (
                SELECT 1
                FROM automate.event_links
                WHERE event_links.event_id = invocations.event_id
              )
            )
          )
      )
  ") || exit

  if jq -e '.results[0].rows[0].complete == true' <<<"$result" >/dev/null; then
    break
  fi
  if ((SECONDS >= poll_deadline)); then
    echo "Run did not finish within five minutes." >&2
    exit 1
  fi
  sleep 1
done

bunx automate.ax search "$event_id"
bunx automate.ax search '"gateway timeout" -retry'

bunx automate.ax query --sql "
  WITH roots AS (
    SELECT DISTINCT context_id
    FROM automate.event_links
    WHERE event_id = '$event_id'
  ),
  family AS (
    SELECT
      roots.context_id AS root_context_id,
      descendants.depth,
      descendants.descendant_context_id AS context_id
    FROM roots
    INNER JOIN automate.context_descendants AS descendants
      ON descendants.context_id = roots.context_id
  )
  SELECT
    family.root_context_id,
    family.depth,
    contexts.id AS context_id,
    contexts.status AS context_status,
    contexts.created_at AS context_created_at,
    contexts.settled_at,
    contexts.error AS context_error,
    actions.name AS action_name,
    actions.status AS action_status,
    actions.completed_at AS action_completed_at,
    actions.error AS action_error,
    actions.output AS action_output
  FROM family
  INNER JOIN automate.contexts AS contexts
    ON contexts.id = family.context_id
  LEFT JOIN automate.actions AS actions
    ON actions.context_id = family.context_id
  ORDER BY
    family.root_context_id,
    family.depth,
    contexts.created_at,
    actions.created_at
"

curl --get https://automate.ax/api/v1/execution-data/manifest \
  --header "Authorization: Bearer $AUTOMATE_SESSION_TOKEN" \
  --data-urlencode "projectId=proj_01..." \
  --data-urlencode "since=2026-08-01T00:00:00Z"

import { defineAction } from "automate.ax"
import { z } from "zod"

export const processOrder = defineAction("Process order")
  .input(z.object({ orderId: z.string() }))
  .retry({ replaySafety: "unsafe" })
  .handler(async ({ input, runtime }) => {
    await runtime.log({
      fields: { orderId: input.orderId },
      level: "info",
      message: "Charging order",
    })
  })

bunx automate.ax query --sql "
  SELECT project_name, automation_identity_key, status, created_at
  FROM automate.root_contexts
  WHERE status = 'failed'
  ORDER BY created_at DESC
  LIMIT 20
"

bunx automate.ax query --file investigation.sql --json

bunx automate.ax search '"gateway timeout" -retry'
bunx automate.ax search cus_01... --limit 50 --json

WITH input AS (
  SELECT websearch_to_tsquery('simple', 'gateway timeout -retry') AS query
)
SELECT
  resource,
  resource_id AS id,
  context_id AS context,
  created_at AS timestamp,
  ts_rank_cd(
    ARRAY[0.05, 0.2, 0.5, 1.0]::real[],
    search_vector,
    input.query,
    32
  ) AS rank,
  content
FROM automate.search_documents
CROSS JOIN input
WHERE search_vector @@ input.query
ORDER BY rank DESC, timestamp DESC
LIMIT 20;

SELECT
  resource,
  resource_id AS id,
  context_id AS context,
  created_at AS timestamp,
  greatest(
    word_similarity('gatewy timeout', title),
    word_similarity('gatewy timeout', content)
  ) AS rank,
  content
FROM automate.search_documents
WHERE 'gatewy timeout' <% title
   OR 'gatewy timeout' <% content
   OR identifiers ILIKE '%cus_01...%'
ORDER BY rank DESC, timestamp DESC
LIMIT 20;

bunx automate.ax data schema
bunx automate.ax data schema --sql
bunx automate.ax data status --json

SELECT
  descendants.depth,
  outputs.context_id,
  outputs.type,
  outputs.data,
  outputs.created_at
FROM automate.context_descendants AS descendants
INNER JOIN automate.outputs
  ON outputs.context_id = descendants.descendant_context_id
WHERE descendants.context_id = 'actx_01...'
ORDER BY outputs.output_seq;

WITH family AS (
  SELECT descendant_context_id AS context_id
  FROM automate.context_descendants
  WHERE context_id = 'actx_01...'
)
SELECT
  invocations.id,
  actions.context_id AS origin_context_id,
  actions.id AS scheduling_action_id,
  invocations.entrypoint,
  invocations.run_at,
  invocations.processed_at,
  invocations.event_id,
  delivery_links.context_id AS delivery_context_id
FROM family
INNER JOIN automate.actions
  ON actions.context_id = family.context_id
INNER JOIN automate.automation_invocations AS invocations
  ON invocations.idempotency_key = actions.id
LEFT JOIN automate.event_links AS delivery_links
  ON delivery_links.event_id = invocations.event_id
ORDER BY invocations.run_at;

SELECT
  created_at,
  level,
  message,
  context_id,
  action_invocation_id,
  attempt,
  fields
FROM automate.logs
WHERE level IN ('warn', 'error')
ORDER BY created_at DESC
LIMIT 100;

SELECT id, payload->>'customerId' AS customer_id
FROM automate.events
WHERE event_type = 'stripe.customer.updated';

bunx automate.ax data export --output ./execution-data.tar.gz
bunx automate.ax data clear

bunx automate.ax data clear --yes
bunx automate.ax data sync