GeezerVisonThe World Wide Web, restored to 800 pixels of glory. | |||||||
| Home|About|Gaming cabinet|Archives|How it works|Starter sites | |||||||
GeezerVison is showing github.com — fix(receiver): harden prefetch and listener lifecycle by GefMar · Pull Request #645 · taskiq-python/taskiq Conversation
|
Codecov Report❌ Patch coverage is
Additional details and impacted files@@ Coverage Diff @@ ## master #645 +/- ## ========================================== + Coverage 81.29% 82.49% +1.20% ========================================== Files 69 69 Lines 2577 2697 +120 ========================================== + Hits 2095 2225 +130 + Misses 482 472 -10 ☔ View full report in Codecov by Harness. 🚀 New features to boost your workflow:
|
Sorry, something went wrong.
There was an error while loading. Please reload this page.
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
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
There was an error while loading. Please reload this page.
- 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
There was an error while loading. Please reload this page.
) * 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 taskiq-python#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: taskiq-python#528 * refactor(receiver): simplify prefetch queue cleanup
There was an error while loading. Please reload this page.
Successfully merging this pull request may close these issues.
max-prefetch argument doesn't work as expected
There was an error while loading. Please reload this page.