Celery Redis Plus

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

Quick Example

from celery import Celery
import celery_redis_plus  # Register valkey:// transport

app = Celery("myapp")
app.config_from_object(
    {
        "broker_url": "valkey://localhost:6379/0",
    }
)


@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 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