List backfills
curl --request GET \
--url https://api.example.com/api/v1/beam/backfillsimport requests
url = "https://api.example.com/api/v1/beam/backfills"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/api/v1/beam/backfills', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/api/v1/beam/backfills",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/api/v1/beam/backfills"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/api/v1/beam/backfills")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/api/v1/beam/backfills")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_bodyBackfills
List backfills
Returns the backfill jobs created by your API key’s user.
GET
/
api
/
v1
/
beam
/
backfills
List backfills
curl --request GET \
--url https://api.example.com/api/v1/beam/backfillsimport requests
url = "https://api.example.com/api/v1/beam/backfills"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/api/v1/beam/backfills', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/api/v1/beam/backfills",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/api/v1/beam/backfills"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/api/v1/beam/backfills")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/api/v1/beam/backfills")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_bodyReturns the backfill jobs created by your API key’s user, newest first.
Response:
Response fields:
Job statuses:
curl -X GET https://api.allium.so/api/v1/beam/backfills \
-H "X-API-Key: ${ALLIUM_API_KEY}"
[
{
"job_id": "f47ac10b-58cc-4372-a567-0e02b2c3d479",
"workflow_id": "beam-backfill-org123-f47ac10b-58cc-4372-a567-0e02b2c3d479",
"organization_id": "org123",
"org_team_user_id": "otu_abc123",
"status": "transporting",
"job_name": "USDC transfers on Base — Sep 2026",
"table": "intermediate.base_assets.int_base_assets__erc20_token_transfers_stream_compat",
"partition_key": "block_timestamp",
"backfill_start": "2026-09-01T00:00:00+00:00",
"backfill_end": "2026-10-01T00:00:00+00:00",
"filter_column": "token_address",
"filter_values": ["0x833589fcd6edb6e08f4c7c32d4f71b54bda02913"],
"transforms": [],
"destinations": [
{ "type": "kafka", "name": "base-usdc-transfers-backfill", "uid": "..." }
],
"static_egress_ip": false,
"num_chunks": 1000,
"chunks_left": 423,
"error_message": null,
"time_created": "2026-10-15T10:30:00Z",
"time_completed": null
}
]
| Field | Description |
|---|---|
job_id | Unique job identifier |
org_team_user_id | User who created the job |
status | Current job state — see statuses below |
job_name | Display name provided at creation |
table | Source Allium table |
partition_key | "block_timestamp" |
backfill_start / backfill_end | Window bounds (inclusive start, exclusive end) |
filter_column / filter_values | Column filter applied to the job, or null if none |
transforms | Transforms applied to the job. Default: [] |
num_chunks | Total chunks to deliver, or null while the job is staging |
chunks_left | Chunks remaining to deliver. Counts down to 0. |
error_message | Error details for failed jobs, otherwise null |
time_created | ISO 8601 UTC timestamp |
time_completed | ISO 8601 UTC timestamp, or null if not yet finished |
| Status | Description |
|---|---|
staging | Preparing data for delivery |
transporting | Delivering data to destinations |
completed | All chunks delivered successfully |
failed | Job encountered an error (see error_message) |
cancelled | Job was cancelled with Cancel backfill |
Was this page helpful?