Track Cargo

GET /cargo/{cargo_id}/tracking

{
  "cargo_id": "crg_abc123def456",
  "status": "processing",
  "status_description": "Batch is being processed by the provider",
  "created_at": "2024-01-15T10:30:00Z",
  "updated_at": "2024-01-15T10:35:00Z"
}

curl http://localhost:8000/cargo/crg_abc123def456/tracking

import httpx
 
cargo_id = "crg_abc123def456"
response = httpx.get(f"http://localhost:8000/cargo/{cargo_id}/tracking")
 
data = response.json()
print(f"Status: {data['status']}")
print(f"Description: {data['status_description']}")

import httpx
import time
 
def wait_for_completion(cargo_id: str, timeout: int = 3600) -> dict:
    """Poll until cargo is processed or timeout."""
    start = time.time()
    terminal_statuses = {"callback_delivered", "callback_failed", "failed"}
    
    while time.time() - start < timeout:
        response = httpx.get(
            f"http://localhost:8000/cargo/{cargo_id}/tracking"
        )
        data = response.json()
        
        if data["status"] in terminal_statuses:
            return data
        
        time.sleep(30)  # Poll every 30 seconds
    
    raise TimeoutError(f"Cargo {cargo_id} not completed in {timeout}s")