curl --request GET \
  --url https://operator.opus.com/job/{YOUR_JOB_EXECUTION_ID}/audit \
  --header 'x-service-key: {YOUR_SERVICE_KEY}'

import requests

url = "https://operator.opus.com/job/{YOUR_JOB_EXECUTION_ID}/audit"
headers = {"x-service-key": "{YOUR_SERVICE_KEY}"}

response = requests.get(url, headers=headers)
audit = response.json()

print(f"Progress: {audit['nb_executed_nodes']}/{audit['nb_nodes']} nodes")
print(f"Running:  {audit['running_node'] or '(none)'}")
print(f"Failed:   {audit['nb_failed_nodes']} -> {audit['failed_nodes']}")

for node_id, data in audit['audit']['nodes_execution_data'].items():
    print(f"\nNode {node_id}:")
    print(data)

const response = await fetch(
  "https://operator.opus.com/job/{YOUR_JOB_EXECUTION_ID}/audit",
  {
    method: "GET",
    headers: {
      "x-service-key": "{YOUR_SERVICE_KEY}",
    },
  }
);

const audit = await response.json();
console.log(`Progress: ${audit.nb_executed_nodes}/${audit.nb_nodes} nodes`);
console.log(`Running:  ${audit.running_node || "(none)"}`);
console.log(`Failed:   ${audit.nb_failed_nodes} -> ${audit.failed_nodes}`);

for (const [nodeId, data] of Object.entries(audit.audit.nodes_execution_data)) {
  console.log(`\nNode ${nodeId}:`, data);
}

{
  "nb_nodes": 5,
  "executed_nodes": ["{NODE_ID_1}", "{NODE_ID_2}"],
  "nb_executed_nodes": 2,
  "running_node": "{NODE_ID_3}",
  "next_node_to_execute": "{NODE_ID_4}",
  "remaining_nodes_to_execute": ["{NODE_ID_4}", "{NODE_ID_5}"],
  "failed_nodes": [],
  "nb_failed_nodes": 0,
  "audit": {
    "nodes_execution_data": {
      "{NODE_ID_1}": {
        "{KEY}": "{VALUE}"
      },
      "{NODE_ID_2}": {
        "{KEY}": "{VALUE}"
      }
    }
  }
}