feat(coprocessor): add a non-blocking, distributed locking mechanism in tfhe-worker#1550

Merged

antoniupop merged 33 commits intorelease/0.10.xfrom

feature/tfhe-worker/scalability

Dec 29, 2025

Commits on Dec 29, 2025

feat(coprocessor): create dependence_chain table

goshawk-3
authored and
antoniupop
committed
feat(coprocessor): coordinate dependence-chain processing across multiple workers

goshawk-3
authored and
antoniupop
committed
test(coprocessor): ensure both acquire_next_lock and work-stealing features

goshawk-3
authored and
antoniupop
committed
fix(coprocessor): fix work-stealing when a lock has expired

goshawk-3
authored and
antoniupop
committed
fix(coprocessor): update the flow of acquire/extend/release chain_id lock

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): update sqlx cache

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): improve logging for dcid locking

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): disable fallback for dependence_chain_id locking

goshawk-3
authored and
antoniupop
committed
fix(coprocessor): update in-memory lock info on extend_current_lock

goshawk-3
authored and
antoniupop
committed
fix(coprocessor): lock another dcid and continue processing

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): update sqlx cache

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): add idx_dependence_chain_processing_by_worker

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): observe query timings in tfhe-worker

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): implement both max_lock_ttl_sec and disable_dcid_locking options

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): update sqlx cache

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): update last_updated_at when releasing a lock

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): support --dcid-timeslice-sec CLI param, tfhe-worker

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): solve dcid unit-tests issue

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): enable lock re-acquisition once the timeslice has been exceeded

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): enable default timeslice

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): run cleanup procedure to delete old processed dcids

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): acquire locks only on DCIDs that are ready for computation

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): update charts with new tfhe-worker args

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): handle case no-dcid-available

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): bump chart version

goshawk-3
authored and
antoniupop
committed
chore(coprocessor): notify work available if dependency count reaches zero

goshawk-3
authored and
antoniupop
committed
fix(coprocessor): add dependence chain index on last_updated when processed
antoniupop
committed
fix(coprocessor): update is_completed only where a CT is inserted in DB
antoniupop
committed
fix(coprocessor): restrict update of computation completion to uncompleted computations
antoniupop
committed
fix(coprocessor): prevent dependence cycle overestimation on trivial encrypt handles
antoniupop
committed
fix(coprocessor): update test for completion of processing of dcid
antoniupop
committed
fix(coprocessor): add missing partial indexes on ciphertexts and ciphertext_digest tables
antoniupop
committed
feat(coprocessor): add transaction dependence chains in HL (#1651)

antoniupop
and
rudy-6-4
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(coprocessor): add a non-blocking, distributed locking mechanism in tfhe-worker#1550

feat(coprocessor): add a non-blocking, distributed locking mechanism in tfhe-worker#1550
antoniupop merged 33 commits intorelease/0.10.xfrom
feature/tfhe-worker/scalability

Commits on Dec 29, 2025

feat(coprocessor): create dependence_chain table

feat(coprocessor): coordinate dependence-chain processing across multiple workers

test(coprocessor): ensure both acquire_next_lock and work-stealing features

fix(coprocessor): fix work-stealing when a lock has expired

fix(coprocessor): update the flow of acquire/extend/release chain_id lock

chore(coprocessor): update sqlx cache

chore(coprocessor): improve logging for dcid locking

chore(coprocessor): disable fallback for dependence_chain_id locking

fix(coprocessor): update in-memory lock info on extend_current_lock

fix(coprocessor): lock another dcid and continue processing

chore(coprocessor): update sqlx cache

chore(coprocessor): add idx_dependence_chain_processing_by_worker

chore(coprocessor): observe query timings in tfhe-worker

chore(coprocessor): implement both max_lock_ttl_sec and disable_dcid_locking options

chore(coprocessor): update sqlx cache

chore(coprocessor): update last_updated_at when releasing a lock

chore(coprocessor): support --dcid-timeslice-sec CLI param, tfhe-worker

chore(coprocessor): solve dcid unit-tests issue

chore(coprocessor): enable lock re-acquisition once the timeslice has been exceeded

chore(coprocessor): enable default timeslice

chore(coprocessor): run cleanup procedure to delete old processed dcids

chore(coprocessor): acquire locks only on DCIDs that are ready for computation

chore(coprocessor): update charts with new tfhe-worker args

chore(coprocessor): handle case no-dcid-available

chore(coprocessor): bump chart version

chore(coprocessor): notify work available if dependency count reaches zero

fix(coprocessor): add dependence chain index on last_updated when processed

fix(coprocessor): update is_completed only where a CT is inserted in DB

fix(coprocessor): restrict update of computation completion to uncompleted computations

fix(coprocessor): prevent dependence cycle overestimation on trivial encrypt handles

fix(coprocessor): update test for completion of processing of dcid

fix(coprocessor): add missing partial indexes on ciphertexts and ciphertext_digest tables

feat(coprocessor): add transaction dependence chains in HL (#1651)