Skip to main content
GET
/
api
/
v1
/
beam
/
backfills
List backfills
curl --request GET \
  --url https://api.example.com/api/v1/beam/backfills
GET /api/v1/beam/backfills
Returns all backfill jobs created by the authenticated user’s organization, ordered by creation time. 
curl -X GET https://api.allium.so/api/v1/beam/backfills \
  -H "X-API-Key: ${ALLIUM_API_KEY}"
Response: 
[
  {
    "job_id": "f47ac10b-58cc-4372-a567-0e02b2c3d479",
    "workflow_id": "beam-backfill-org123-f47ac10b-58cc-4372-a567-0e02b2c3d479",
    "organization_id": "org123",
    "status": "transporting",
    "job_name": "USDC transfers Jan 2024",
    "table": "ETHEREUM.RAW.ERC20_TOKEN_TRANSFER",
    "partition_key": "block_timestamp",
    "backfill_start": "2024-01-01T00:00:00",
    "backfill_end": "2024-02-01T00:00:00",
    "filter_column": "token_address",
    "filter_values": ["0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48"],
    "destinations": [
      { "type": "kafka", "name": "usdc-transfers-backfill", "uid": "..." }
    ],
    "static_egress_ip": false,
    "num_chunks": 1000,
    "chunks_left": 423,
    "error_message": null,
    "time_created": "2024-04-27T10:30:00Z",
    "time_completed": null
  }
]
Response fields:
FieldDescription
job_idUnique job identifier
statusCurrent job state — see statuses below
job_nameDisplay name provided at creation
tableSource Snowflake table
partition_key"block" or "block_timestamp"
backfill_start / backfill_endWindow bounds (inclusive start, exclusive end)
filter_column / filter_valuesColumn filter applied to the export, or null if none
num_chunksTotal parquet files staged from Snowflake, or null while still staging
chunks_leftRemaining files to deliver; counts down to 0
error_messageSet on failed jobs; null otherwise
time_createdISO 8601 UTC timestamp
time_completedISO 8601 UTC timestamp, or null if not yet finished
Job statuses:
StatusDescription
stagingExporting data from Snowflake to GCS
transportingDelivering parquet chunks to destinations
completedAll chunks delivered successfully
failedJob encountered an error (see error_message)
cancelledJob was cancelled via the cancel endpoint