Retrieve Async Job Status and Compliance Metrics

import agribackup
from agribackup.rest import ApiException
import time

configuration = agribackup.Configuration(host="https://live.agribackup.com/api/v1")
configuration.api_key['ApiKeyAuth'] = 'sk_live_YOUR_API_KEY'

JOB_ID = "job_998877"
TERMINAL_PHASES = {"COMPLETED", "FAILED"}

with agribackup.ApiClient(configuration) as api_client:
    api_instance = agribackup.EnterpriseJobsApi(api_client)
    while True:
        try:
            job = api_instance.get_job_status(job_id=JOB_ID)
            print(f"Phase: {job.phase} | Processed: {job.processed_records}/{job.total_records}")

            if job.phase in TERMINAL_PHASES:
                if job.phase == "COMPLETED":
                    print(f"Job complete! Hedera TX: {job.hedera_transaction_id}")
                    print(f"Compliant: {job.compliant_units} | High Risk: {job.high_risk_units}")
                else:
                    print(f"Job failed with {len(job.errors)} error(s):")
                    for err in job.errors:
                        print(f"  [{err.code}] {err.field}: {err.reason}")
                break

            time.sleep(3)
        except ApiException as e:
            print("Exception when calling get_job_status: %s\n" % e)
            break

import { AgriBackupClient } from '@agribackup/sdk';

const client = new AgriBackupClient({
  apiKey: 'sk_live_YOUR_API_KEY',
  baseUrl: 'https://live.agribackup.com/api/v1'
});

async function pollJobStatus(jobId) {
  const terminalPhases = new Set(['COMPLETED', 'FAILED']);

  while (true) {
    try {
      const job = await client.jobs.getJobStatus({ jobId });
      console.log(`Phase: ${job.phase} | Processed: ${job.processedRecords}/${job.totalRecords}`);

      if (terminalPhases.has(job.phase)) {
        if (job.phase === 'COMPLETED') {
          console.log(`Job complete! Hedera TX: ${job.hederaTransactionId}`);
          console.log(`Compliant: ${job.compliantUnits} | High Risk: ${job.highRiskUnits}`);
        } else {
          console.log(`Job failed with ${job.errors.length} error(s):`);
          job.errors.forEach(err => {
            console.log(`  [${err.code}] ${err.field}: ${err.reason}`);
          });
        }
        break;
      }

      await new Promise(resolve => setTimeout(resolve, 3000));
    } catch (error) {
      console.error('Error polling job status:', error);
      break;
    }
  }
}

pollJobStatus('job_998877');

curl --request GET \
  --url https://live.agribackup.com/api/v1/enterprise/eudr/jobs/job_998877 \
  --header 'X-API-Key: sk_live_YOUR_API_KEY'