Skip to main content
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
Documentation
Released on October 16, 2025
Features
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_limit to ConcurrencyLeaseStorage protocol #18970 by @zzstoatzz
- Add holder parameter to V2 concurrency endpoints #18887 by @zzstoatzz
- Removes followers log from Redis
CausalOrdering implementation #18870 by @desertaxle
- Update lease storage to include holder indexing and lookup via Lua scripts #18897 by @zzstoatzz
Released on August 14, 2025
Enhancements โโ
- Add Redis-based concurrency lease storage implementation by @desertaxle in #18646
- New
ConcurrencyLeaseStorage class for managing task and flow concurrency limits
- Atomic lease operations using Redis pipelines
- Support for lease expiration tracking and management
Bug Fixes ๐
- 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
ephemeral prefix
- New
PREFECT_REDIS_MESSAGING_CONSUMER_TRIM_IDLE_THRESHOLD setting (default: 5 minutes)
Development & Tidiness ๐งน