feat: long-running jobs (polling + callback semantics)#43

Open

knutties wants to merge 32 commits into

mainfrom

feat/long-running-jobs

Commits on Jun 11, 2026

docs: design spec for long-running jobs (polling + callback)

knutties
and
claude
committed
docs: implementation plan for long-running jobs

knutties
and
claude
committed

Commits on Jun 12, 2026

feat(db): add long-running job columns + polls table

knutties
and
claude
committed
feat(models): add WAITING and POLLING ExecutionStatus variants

knutties
and
claude
committed
feat(models): add Poll row + PollClassification enum

knutties
and
claude
committed
feat(db): add polls insert + list helpers

knutties
and
claude
committed
refactor(db): polls::insert returns inserted row (mirror attempts pattern)
knutties
committed
feat(db): extend executions::claim to pick up WAITING rows
knutties
committed
feat(db): add long-running execution transition helpers

knutties
and
claude
committed
refactor(db): transition_to_waiting returns rows_affected + explicit poll_count reset

knutties
and
claude
committed
feat(db): extend cancel to allow WAITING; return previous status + poll_url

knutties
and
claude
committed
feat(db): persist async_max_wait_ms / async_max_polls on jobs

knutties
and
claude
committed
feat(api): validate endpoint async block on create/update

knutties
and
claude
committed
feat(api): validate + persist job async_overrides

knutties
and
claude
committed
fix: skip range check when no async_overrides; add max_polls range test

knutties
and
claude
committed
refactor(common): lift secret helpers from worker; reusable from api

knutties
and
claude
committed
feat(template): add execution.callback_url / .org_id / .workspace_id

knutties
and
claude
committed
refactor(worker): use cached SchemaRegistry::get_org_ws for tenant lookup

knutties
and
claude
committed
feat(worker): detect async status code on initial dispatch

knutties
and
claude
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: long-running jobs (polling + callback semantics)#43

feat: long-running jobs (polling + callback semantics)#43
knutties wants to merge 32 commits into
mainfrom
feat/long-running-jobs

Commits on Jun 11, 2026

docs: design spec for long-running jobs (polling + callback)

docs: implementation plan for long-running jobs

Commits on Jun 12, 2026

feat(db): add long-running job columns + polls table

feat(models): add WAITING and POLLING ExecutionStatus variants

feat(models): add Poll row + PollClassification enum

feat(db): add polls insert + list helpers

refactor(db): polls::insert returns inserted row (mirror attempts pattern)

feat(db): extend executions::claim to pick up WAITING rows

feat(db): add long-running execution transition helpers

refactor(db): transition_to_waiting returns rows_affected + explicit poll_count reset

feat(db): extend cancel to allow WAITING; return previous status + poll_url

feat(db): persist async_max_wait_ms / async_max_polls on jobs

feat(api): validate endpoint async block on create/update

feat(api): validate + persist job async_overrides

fix: skip range check when no async_overrides; add max_polls range test

refactor(common): lift secret helpers from worker; reusable from api

feat(template): add execution.callback_url / .org_id / .workspace_id

refactor(worker): use cached SchemaRegistry::get_org_ws for tenant lookup

feat(worker): detect async status code on initial dispatch

Commits on Jun 13, 2026

test(worker): URL resolution + Retry-After parsing unit tests

fix(worker): use safe slice in parse_retry_after weekday-strip

feat(worker): process_poll with classification + retry-from-poll + transient handling

test(worker): add classify overlap test; warn on null polling_deadline

feat(worker): branch claim flow on RUNNING vs POLLING

feat(api): best-effort DELETE on poll_url when cancelling WAITING execution

feat(api): job cancel propagates to WAITING executions + best-effort DELETE

feat(api): add callback /complete and /fail routes

fix(api): require auth on callback routes; persist error payload on fail

feat(api): expose polls list on execution endpoint

test(mock): add programmable /async routes for long-running tests

fix(long-running): per-job override propagation, metrics emit, fail callback race, callback-only churn

chore: update Cargo.lock for kronos-api reqwest dep