0.2.8
Released on December 19, 2025 Enhancements โโ- Add retry logic for consumer reconnection on Redis errors #19817 by @zzstoatzz
- Unify definition of
EventBeingProcessedtype #19585 by @saschwartz
- Fix
anyiofail_afterusage #19583 by @saschwartz
0.2.7
Released on November 26, 2025 Features- Parametrize xreadgroup batch size in consumer; Add EventPersister service setting for it #19545 by @saschwartz
- Also parametrize xautoclaim batch size #19557 by @saschwartz
- Remove Python 3.9 support #19273 by @desertaxle
0.2.6
Released on October 16, 2025 Features- Fix race conditions in concurrency lease renewal #19187 by @bunchesofdonald
0.2.5
Released on September 19, 2025 Enhancements- Update task concurrency slot orchestration rules to work with global concurrency limits #18983 by @desertaxle
- Add pagination support to lease storage
read_active_lease_ids#18973 by @zzstoatzz - Add
list_holders_for_limittoConcurrencyLeaseStorageprotocol #18970 by @zzstoatzz - Add holder parameter to V2 concurrency endpoints #18887 by @zzstoatzz
- Removes followers log from Redis
CausalOrderingimplementation #18870 by @desertaxle - Update lease storage to include holder indexing and lookup via Lua scripts #18897 by @zzstoatzz
0.2.4
Released on August 14, 2025 Enhancements โโ- Add Redis-based concurrency lease storage implementation by @desertaxle in #18646
- New
ConcurrencyLeaseStorageclass for managing task and flow concurrency limits - Atomic lease operations using Redis pipelines
- Support for lease expiration tracking and management
- New
- Fix Redis stream trimming blocked by inactive consumer groups by @zzstoatzz in #18642
- Added idle threshold checking to prevent abandoned consumer groups from blocking stream trimming
- Automatic cleanup of empty consumer groups with
ephemeralprefix - New
PREFECT_REDIS_MESSAGING_CONSUMER_TRIM_IDLE_THRESHOLDsetting (default: 5 minutes)
- Bump minimum
prefectversion to 3.4.9 by @desertaxle in #18709