fix(jobs): fixes for concurrent ML processing jobs#1261

Merged

mihow merged 15 commits into

mainfrom

fix/jobs-row-lock-drop-select-for-update

Apr 23, 2026

Commits on Apr 21, 2026

fix(jobs): drop select_for_update in _update_job_progress to break row-lock contention

mihow
and
claude
committed
fix(jobs): short-circuit JobLogHandler.emit to break log-UPDATE contention
mihow
committed
feat(jobs): add JOB_LOG_PERSIST_ENABLED flag + local repro docs
mihow
committed
perf(jobs): wrap process_nats_pipeline_result with cachalot_disabled
mihow
committed
chore(jobs): address PR #1261 review feedback

mihow
and
claude
committed
fix(jobs): narrow job.save() to update_fields in _update_job_progress

mihow
and
claude
committed
feat(settings): wire NATS_TASK_TTR env var with 60s default

mihow
and
claude
committed
feat(jobs): fair worker polling via last-touched ordering

mihow
and
claude
committed
feat(jobs): default ids_only to limit=1 for pop()-style polling
mihow
committed
fix(jobs): randomize ids_only ordering instead of updated_at sort
mihow
committed
test(jobs): update ids_only test for pop()-style default

mihow
and
claude
committed
feat(jobs): heartbeat on idle ids_only polls
mihow
committed

Commits on Apr 22, 2026

Commits on Apr 23, 2026

docs(jobs): address PR #1261 review feedback

mihow
and
claude
committed