Metadata-Version: 2.4
Name: celery-redis-plus
Version: 0.3.0
Summary: Enhanced Kombu Valkey/Redis transport for Celery
Project-URL: Homepage, https://github.com/oliverhaas/celery-redis-plus
Project-URL: Documentation, https://oliverhaas.github.io/celery-redis-plus/
Project-URL: Repository, https://github.com/oliverhaas/celery-redis-plus.git
Author-email: Oliver Haas <ohaas@e1plus.de>
License: MIT
License-File: LICENSE
Keywords: celery,kombu,message-queue,priority-queue,redis,valkey
Classifier: Development Status :: 3 - Alpha
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.13
Classifier: Programming Language :: Python :: 3.14
Classifier: Topic :: System :: Distributed Computing
Classifier: Typing :: Typed
Requires-Python: >=3.13
Requires-Dist: celery>=5.5.0
Requires-Dist: kombu>=5.5.0
Provides-Extra: hiredis
Requires-Dist: redis[hiredis]<8,>=7.1.0; extra == 'hiredis'
Provides-Extra: libvalkey
Requires-Dist: valkey[libvalkey]<7,>=6.1.0; extra == 'libvalkey'
Provides-Extra: redis
Requires-Dist: redis<8,>=7.1.0; extra == 'redis'
Provides-Extra: valkey
Requires-Dist: valkey<7,>=6.1.0; extra == 'valkey'
Description-Content-Type: text/markdown

# Celery Redis Plus

[![PyPI version](https://img.shields.io/pypi/v/celery-redis-plus.svg)](https://pypi.org/project/celery-redis-plus/)
[![CI](https://github.com/oliverhaas/celery-redis-plus/actions/workflows/ci.yml/badge.svg)](https://github.com/oliverhaas/celery-redis-plus/actions/workflows/ci.yml)

Enhanced Redis/Valkey transport for Celery/Kombu with native delayed delivery, improved reliability, full priority support, and reliable fanout.

## Quick Example

```python
from celery import Celery
import celery_redis_plus  # Register valkey:// transport
from celery_redis_plus import DelayedDeliveryBootstep

app = Celery('myapp')
app.config_from_object({
    'broker_url': 'valkey://localhost:6379/0',
})
app.steps['consumer'].add(DelayedDeliveryBootstep)

@app.task
def my_task():
    print("Hello!")

# Native delayed delivery - stored in Redis, not worker memory
my_task.apply_async(countdown=120)

# Full priority support (0-255, RabbitMQ semantics)
my_task.apply_async(priority=90)
```

## Documentation

See the [full documentation](https://oliverhaas.github.io/celery-redis-plus/) for installation, configuration, and API reference.

## Supported Versions

|         | Python 3.13 | Python 3.14 |
|---------|:-----------:|:-----------:|
| Celery 5.5+ | ✓ | ✓ |

Requires Redis >= 7.0 (for BZMPOP) or Valkey (any version).

## License

MIT
