Modules
Elixir port of Python's Celery distributed task queue (celery.Celery),
wire-compatible with Python Celery (Protocol v1 & v2) and backed by Kombu and Redis
for transport and result storage.
AMQP / Kombu task routing, queue configuration, and task message publishing
(ported from celery.app.amqp).
Redis result store backend for Celery (ported from celery.backends.redis.RedisBackend
and celery.backends.base.KeyValueStoreBackend).
An issue writing or reading from the result backend.
Celery Canvas workflow primitives (signature, chain, group, chord)
compatible with Python Celery's wire protocol.
Serializable task invocation signature (celery.canvas.Signature / subtask).
A task part of the chord raised an exception.
Celery configuration structure and defaults (ported from celery.app.defaults).
Base Celery error.
Exception that a task may raise to ignore the task without recording a result or failure.
The task has invalid arguments or options.
The task's max_retries limit was exceeded.
The task is not registered in the Celery registry.
Celery Task Message Protocol v1 and v2 encoder and decoder (ported from celery.app.amqp
and celery.worker.request).
Task registry for Celery applications (ported from celery.app.registry.TaskRegistry).
Exception that a task may raise to reject the message via AMQP/Kombu reject (requeue: true | false).
Exception reconstructed from a remote task failure stored in the Redis result backend.
Task result handle (AsyncResult in Python Celery, ported from celery.result.AsyncResult).
Result handle for a group of tasks (GroupResult in Python Celery).
Exception raised by Celery.Task.retry/2 to signal that the task is to be retried later.
Built-in Celery task states and precedence rules (ported from celery.states).
Celery Task behaviour, @task attribute decorator, deftask macro, and runtime self struct
(ported from celery.app.task.Task).
Task execution request context (self.request in Python Celery, ported from celery.app.task.Context).
Metadata and binding specification for a registered Celery task.
The task has been revoked.
The operation timed out waiting for a result or task execution.
Task execution tracer (ported from celery.app.trace.build_tracer).
Celery Worker / Consumer OTP GenServer (ported from celery.worker).
Remote control and inspection commands for Celery workers over Kombu.Pidbox
(ported from celery.worker.control and celery.app.control).
Worker task request wrapper (ported from celery.worker.request.Request).