Celery Deprecation Timeline

• Removals for version 3.2
• Removals for version 4.0
  • Old Task API
    • Compat Task Modules
    • TaskSet
    • Magic keyword arguments
  • Task attributes
  • celery.result
  • celery.loader
  • Task_sent signal
  • Modules to Remove
  • Settings
    • BROKER Settings
    • REDIS Result Backend Settings
    • Logging Settings
    • Other Settings
• Removals for version 2.0

Removals for version 3.2

• Module celery.task.trace has been renamed to celery.app.trace as the celery.task package is being phased out. The compat module will be removed in version 3.2 so please change any import from:

  from celery.task.trace import …

  to:

  from celery.app.trace import …

• AsyncResult.serializable() and celery.result.from_serializable will be removed.

  Use instead:

  >>> tup = result.as_tuple()
  >>> from celery.result import result_from_tuple
  >>> result = result_from_tuple(tup)

Removals for version 4.0

Old Task API

Compat Task Modules

• Module celery.decorators will be removed:

  Which means you need to change:

  from celery.decorators import task

Into:

from celery import task

• Module celery.task may be removed (not decided)

  This means you should change:

  from celery.task import task

  into:

  from celery import task

  —and::

  from celery.task import Task

  into:

  from celery import Task

Note that the new Task class no longer uses classmethods for these methods:

• delay
• apply_async
• retry
• apply
• AsyncResult
• subtask

This also means that you can’t call these methods directly on the class, but have to instantiate the task first:

>>> MyTask.delay()          # NO LONGER WORKS
>>> MyTask().delay()        # WORKS!

TaskSet

TaskSet has been renamed to group and TaskSet will be removed in version 4.0.

Old:

>>> from celery.task import TaskSet
>>> TaskSet(add.subtask((i, i)) for i in xrange(10)).apply_async()

New:

>>> from celery import group
>>> group(add.s(i, i) for i in xrange(10))()

Magic keyword arguments

The magic keyword arguments accepted by tasks will be removed in 4.0, so you should start rewriting any tasks using the celery.decorators module and depending on keyword arguments being passed to the task, for example:

from celery.decorators import task
@task()
def add(x, y, task_id=None):
    print("My task id is %r" % (task_id, ))

should be rewritten into:

from celery import task
@task(bind=True)
def add(self, x, y):
    print("My task id is {0.request.id}".format(self))

Task attributes

The task attributes:

• queue
• exchange
• exchange_type
• routing_key
• delivery_mode
• priority

is deprecated and must be set by CELERY_ROUTES instead.

celery.result

• BaseAsyncResult -> AsyncResult.
• TaskSetResult -> GroupResult.
• TaskSetResult.total -> len(GroupResult)
• TaskSetResult.taskset_id -> GroupResult.id

Apply to: AsyncResult, EagerResult:

- ``Result.wait()`` -> ``Result.get()``

• Result.task_id() -> Result.id
• Result.status -> Result.state.

celery.loader

• current_loader() -> current_app.loader
• load_settings() -> current_app.conf

Task_sent signal

The task_sent signal will be removed in version 4.0. Please use the before_task_publish and after_task_publush signals instead.

Modules to Remove

• celery.execute

  This module only contains send_task, which must be replaced with celery.send_task instead.

• celery.decorators

  See Compat Task Modules

• celery.log

  Use celery.log instead.

• celery.messaging

  Use celery.amqp instead.

• celery.registry

  Use celery.app.registry instead.

• celery.task.control

  Use celery.control instead.

• celery.task.schedules

  Use celery.schedules instead.

• celery.task.chords

  Use celery.chord() instead.

Settings

BROKER Settings

REDIS Result Backend Settings

Logging Settings

Other Settings

Removals for version 2.0

• The following settings will be removed:

• CELERY_LOADER definitions without class name.

  E.g. celery.loaders.default, needs to include the class name: celery.loaders.default.Loader.

• TaskSet.run(). Use celery.task.base.TaskSet.apply_async()

  instead.

• The module celery.task.rest; use celery.task.http instead.