Tags: taskiq-python/taskiq
Tags
fix(receiver): harden prefetch and listener lifecycle (#645) * fix(receiver): harden prefetch and listener lifecycle Track delivery and prefetch capacity ownership across shutdown paths. Close pending listener reads, preserve late deliveries, and restore fail-fast transport error propagation. Keep middleware accounting balanced, report discarded deliveries, and retain deferred lifecycle diagnostics when task group failures overlap. * fix(receiver): tighten prefetch ownership checks Reject invalid prefetch values before receiver retries and retain delivery accounting until execution capacity is acquired. Add deterministic coverage for CLI defaults, cancellation races, and listener lifecycle cleanup. Refs #528 * fix(receiver): simplify prefetch listener lifecycle - remove undocumented prefetch middleware hooks and metrics - preserve listener errors during task group failures - restore capacity when callback handoff fails - strengthen shutdown and cleanup coverage Refs: #528 * refactor(receiver): simplify prefetch queue cleanup
PreviousNext