feat(etl): execute durable jobs with lease fencing - #122

Closed

seonghobae wants to merge 97 commits into

ci/hourly-opencode-nvidia-nimfrom

feat/durable-job-lease-worker

Commits on Aug 5, 2026

docs: design lease-fenced durable job worker
seonghobae
committed
956b9ee
docs: plan lease-fenced durable job worker
seonghobae
committed
4f170ec
test: specify durable job lease schema
seonghobae
committed
e4960fe
test: specify worker configuration bounds
seonghobae
committed
8f52630
feat(etl): add durable job lease schema
seonghobae
committed
6155eb8
feat(etl): define fail-closed worker properties
seonghobae
committed
0325b86
feat(etl): register worker configuration
seonghobae
committed
a129333
feat(etl): add fail-closed worker defaults
seonghobae
committed
aeeeb38
test(etl): align claim index contract
seonghobae
committed
faab9de
test(etl): specify lease-fenced job persistence
seonghobae
committed
f1eac6e
test(etl): specify lease value invariants
seonghobae
committed
d037bf1
feat(etl): add immutable lease value
seonghobae
committed
f1d066f
feat(etl): define stale lease failure
seonghobae
committed
b04a105
feat(etl): persist exclusive fenced claims
seonghobae
committed
de7d29d
test(etl): specify atomic leased execution
seonghobae
committed
c118dc5
feat(etl): couple target writes to lease success
seonghobae
committed
72fbed4
test(etl): keep execution collaborators encapsulated
seonghobae
committed
8fffb6b
test(etl): specify bounded worker outcomes
seonghobae
committed
a3b7af4
feat(etl): execute one bounded leased job per poll
seonghobae
committed
de3e5e1
feat(etl): enable conditional worker scheduling
seonghobae
committed
19d3085
test(etl): make lease transition order deterministic
seonghobae
committed
bd48d4a
test(etl): cover stale terminal transitions
seonghobae
committed
379d5cb
test(config): specify durable worker aliases
seonghobae
committed
6fe4162
feat(config): dual-read durable worker settings
seonghobae
committed
aa90cd3
test(etl): specify stored execution identity
seonghobae
committed
f988caa
feat(etl): carry durable execution identity in leases
seonghobae
committed
1716701
feat(etl): claim durable execution identity
seonghobae
committed
108dc12
test(etl): provide worker execution hashes
seonghobae
committed
f43d369
test(etl): verify claimed execution identity
seonghobae
committed
960f6f6
test(etl): specify durable execution ledger
seonghobae
committed
9ac0890
feat(etl): define durable job integrity failure
seonghobae
committed
dcdeb64
feat(etl): centralize SHA-256 digesting
seonghobae
committed
c376189
feat(etl): reuse response ledger for durable jobs
seonghobae
committed
262d53b
feat(etl): commit ledger and target with lease success
seonghobae
committed
b072dac
test(etl): prove atomic ledger target and success
seonghobae
committed
0810937
feat(etl): expose stable integrity failures
seonghobae
committed
de85194
test(etl): cover integrity failure classification
seonghobae
committed
c3752db
test(etl): verify SHA-256 digest utility
seonghobae
committed
8c31ed9
docs: add durable job worker runbook
seonghobae
committed
e536c9b
docs: connect durable intake to lease worker
seonghobae
committed
1b7417f
docs: align lease worker design with response ledger
seonghobae
committed
fcefbf4
docs: record lease-fenced durable execution
seonghobae
committed
a727b87
docs: preserve stacked changelog history
seonghobae
committed
1c44790
test(etl): enforce complete durable execution coverage
seonghobae
committed
cafedca
test(etl): verify complete execution coverage policy
seonghobae
committed
956a392
test(etl): specify SHA-256 failure coverage
seonghobae
committed
5090dfa
feat(etl): make digest failure path testable
seonghobae
committed
02353f3
test(etl): compare expanded coverage includes deterministically
seonghobae
committed
e02e873
test(etl): reject unbounded worker timing configuration
seonghobae
committed
92bc0d2
fix(etl): bound worker delays and lease duration
seonghobae
committed
8d243ac
test(etl): reject overlong repository leases
seonghobae
committed
0273753
fix(etl): enforce repository lease ceiling
seonghobae
committed
1377f6e
docs(etl): document bounded worker timing controls
seonghobae
committed
51d1202
docs(config): expose worker timing ceilings
seonghobae
committed
5af809f
Merge PR #121 exact head into durable job worker stack
seonghobae
committed
c96eb7c
test(etl): align runbook contract with lease-fenced execution
seonghobae
committed
8e91f69
test(etl): cover impossible locked-claim transition
seonghobae
committed
5bafdd5
test(etl): require complete worker outcome evidence
seonghobae
committed
95ed508
fix(etl): complete durable worker outcome evidence
seonghobae
committed
0f77c21
docs(etl): define complete worker outcome accounting
seonghobae
committed
4a58907
docs(changelog): record complete worker outcome accounting
seonghobae
committed
5b7e6d0
fix(changelog): preserve ETL alias namespace
seonghobae
committed
38a1675
fix(changelog): keep historical summary unchanged
seonghobae
committed
6d53965
test(etl): require one terminal worker outcome per poll
seonghobae
committed
5ac536f
fix(etl): count one terminal worker outcome per poll
seonghobae
committed
c66d052
test(etl): align worker metric expectations with terminal outcomes
seonghobae
committed
3f1e23a
test(etl): require nonblocking claim index rollout
seonghobae
committed
a68d84c
fix(etl): keep lease schema migration transactional
seonghobae
committed
a6232dc
fix(etl): build claim index without blocking writers
seonghobae
committed
d1d1444
build(etl): run claim index migration outside transaction
seonghobae
committed
e44ea4a
fix(etl): use session Flyway lock for concurrent indexes
seonghobae
committed
9835495
test(etl): verify concurrent Flyway lock configuration
seonghobae
committed
2797795
docs(etl): document nonblocking claim index rollout
seonghobae
committed
7bde8e1
test(etl): bind claim index evidence to focused runbook
seonghobae
committed
c447bfa
test(etl): keep lease schema migration focused
seonghobae
committed
ec140c5
docs(etl): align worker metrics and migration rollout
seonghobae
committed
1b53a98
docs(changelog): record nonblocking claim index rollout
seonghobae
committed
c2f0802
fix(build): preserve explicit patched Jackson BOM import
seonghobae
committed
9d6f4ba
test(etl): define durable worker retry boundary
seonghobae
committed
36313a6
test(etl): require an active durable execution transaction
seonghobae
committed
e8ec36d
fix(etl): separate durable and synchronous retry boundaries
seonghobae
committed
b734b99
fix(etl): keep durable retries outside the lease transaction
seonghobae
committed
d1405db
docs(etl): record durable retry-boundary evidence
seonghobae
committed
1a5d9c0
test(etl): require transactional success fencing
seonghobae
committed
0b3faf2
fix(etl): require atomic success transaction
seonghobae
committed
9c1670e
test(etl): execute success fencing in its atomic transaction
seonghobae
committed
a7e16e6
docs(etl): record atomic success transaction gate
seonghobae
committed
b4fb360
test(etl): forbid idempotency-owned execution transactions
seonghobae
committed
26d1107
fix(etl): join the lease-fenced execution transaction
seonghobae
committed
c10bfdf
test(etl): prove expired leases roll back durable effects
seonghobae
committed
3a7aa63
test(etl): run idempotency integration cases in transactions
seonghobae
committed
cee0096
Merge cee009681ea0b1ce5f97fd63cd4fe37f18cbeef9 into 68e82f9d7e19623b6f397bd52a4e54d41a472c97
seonghobae
authored
f3c448e

Commits on Aug 6, 2026

Commits on Aug 7, 2026