celery v4.3.0 Release Notes
Release Date: 2019-03-31 // almost 5 years ago-
๐ :release-date: 2019-02-20 5:00 PM IST ๐ :release-by: Omer Katz
- Canvas: :meth:
celery.chain.apply
does not ignore keyword arguments anymore when applying the chain.
Contributed by Korijn van Golen
- Result Set: Don't attempt to cache results in a :class:
celery.result.ResultSet
.
During a join, the results cache was populated using :meth:
celery.result.ResultSet.get
, if one of the results contains an exception, joining unexpectedly failed.The results cache is now removed.
Contributed by Derek Harland
- Application: :meth:
celery.Celery.autodiscover_tasks
now attempts to import the package itself when therelated_name
keyword argument isNone
.
Contributed by Alex Ioannidis
- ๐ Windows Support: On Windows 10, stale PID files prevented celery beat to run.
We now remove them when a :class:
SystemExit
is raised.
Contributed by :github_user:
na387
- Task: Added the new :setting:
task_acks_on_failure_or_timeout
setting.
Acknowledging SQS messages on failure or timing out makes it impossible to use dead letter queues.
We introduce the new option acks_on_failure_or_timeout, to ensure we can totally fallback on native SQS message lifecycle, using redeliveries for retries (in case of slow processing or failure) and transitions to dead letter queue after defined number of times.
Contributed by Mario Kostelac
- RabbitMQ Broker: Adjust HA headers to work on RabbitMQ 3.x.
This change also means we're ending official support for RabbitMQ 2.x.
Contributed by Asif Saif Uddin
- ๐ป Command Line: Improve :program:
celery update
error handling.
Contributed by Federico Bond
- Canvas: Support chords with :setting:
task_always_eager
set toTrue
.
Contributed by Axel Haustant
- Result Backend: Optionally store task properties in result backend.
Setting the :setting:
result_extended
configuration option toTrue
enables storing additional task properties in the result backend.Contributed by John Arnold
- Couchbase Result Backend: Allow the Couchbase result backend to automatically detect the serialization format.
Contributed by Douglas Rohde
- ๐ New Result Backend: Added the Azure Block Blob Storage result backend.
The backend is implemented on top of the azure-storage library which uses Azure Blob Storage for a scalable low-cost PaaS backend.
The backend was load tested via a simple nginx/gunicorn/sanic app hosted on a DS4 virtual machine (4 vCores, 16 GB RAM) and was able to handle 600+ concurrent users at ~170 RPS.
The commit also contains a live end-to-end test to facilitate verification of the backend functionality. The test is activated by setting the
AZUREBLOCKBLOB_URL
environment variable toazureblockblob://{ConnectionString}
where the value forConnectionString
can be found in theAccess Keys
pane of a Storage Account resources in the Azure Portal.Contributed by Clemens Wolff
- Task: :meth:
celery.app.task.update_state
now accepts keyword arguments.
This allows passing extra fields to the result backend. These fields are unused by default but custom result backends can use them to determine how to store results.
Contributed by Christopher Dignam
- Gracefully handle consumer :class:
kombu.exceptions.DecodeError
.
When using the v2 protocol the worker no longer crashes when the consumer encounters an error while decoding a message.
Contributed by Steven Sklar
- ๐ Deployment: Fix init.d service stop.
Contributed by Marcus McHale
- Django: Drop support for Django < 1.11.
Contributed by Asif Saif Uddin
- Django: Remove old djcelery loader.
Contributed by Asif Saif Uddin
- Result Backend: :class:
celery.worker.request.Request
now passes :class:celery.app.task.Context
to the backend's store_result functions.
Since the class currently passes
self
to these functions, revoking a task resulted in corrupted task result data when django-celery-results was used.Contributed by Kiyohiro Yamaguchi
- ๐ท Worker: Retry if the heartbeat connection dies.
Previously, we keep trying to write to the broken connection. This results in a memory leak because the event dispatcher will keep appending the message to the outbound buffer.
Contributed by Raf Geens
- Celery Beat: Handle microseconds when scheduling.
Contributed by K Davis
- Asynpool: Fixed deadlock when closing socket.
Upon attempting to close a socket, :class:
celery.concurrency.asynpool.AsynPool
only removed the queue writer from the hub but did not remove the reader. This led to a deadlock on the file descriptor and eventually the worker stopped accepting new tasks.We now close both the reader and the writer file descriptors in a single loop iteration which prevents the deadlock.
Contributed by Joshua Engelman
- Celery Beat: Correctly consider timezone when calculating timestamp.
Contributed by :github_user:
yywing
- Celery Beat: :meth:
celery.beat.Scheduler.schedules_equal
can now handle either arguments being aNone
value.
Contributed by :github_user:
ratson
- ๐ Documentation/Sphinx: Fixed Sphinx support for shared_task decorated functions.
Contributed by Jon Banafato
- ๐ New Result Backend: Added the CosmosDB result backend.
This change adds a new results backend. The backend is implemented on top of the pydocumentdb library which uses Azure CosmosDB for a scalable, globally replicated, high-performance, low-latency and high-throughput PaaS backend.
Contributed by Clemens Wolff
- Application: Added configuration options to allow separate multiple apps to run on a single RabbitMQ vhost.
The newly added :setting:
event_exchange
and :setting:control_exchange
configuration options allow users to use separate Pidbox exchange and a separate events exchange.This allow different Celery applications to run separately on the same vhost.
Contributed by Artem Vasilyev
- Result Backend: Forget parent result metadata when forgetting a result.
Contributed by :github_user:
tothegump
- Task Store task arguments inside :class:
celery.exceptions.MaxRetriesExceededError
.
Contributed by Anthony Ruhier
- Result Backend: Added the :setting:
result_accept_content
setting.
This feature allows to configure different accepted content for the result backend.
A special serializer (
auth
) is used for signed messaging, however the result_serializer remains in json, because we don't want encrypted content in our result backend.To accept unsigned content from the result backend, we introduced this new configuration option to specify the accepted content from the backend.
Contributed by Benjamin Pereto
- Canvas: Fixed error callback processing for class based tasks.
Contributed by Victor Mireyev
- ๐ New Result Backend: Added the S3 result backend.
Contributed by Florian Chardin
- Task: Added support for Cythonized Celery tasks.
Contributed by Andrey Skabelin
- Riak Result Backend: Warn Riak backend users for possible Python 3.7 incompatibilities.
Contributed by George Psarakis
- Python Runtime: Added Python 3.7 support.
Contributed by Omer Katz & Asif Saif Uddin
- Auth Serializer: Revamped the auth serializer.
The auth serializer received a complete overhaul. It was previously horribly broken.
We now depend on cryptography instead of pyOpenSSL for this serializer.
Contributed by Benjamin Pereto
- ๐ป Command Line: :program:
celery report
now reports kernel version along with other platform details.
Contributed by Omer Katz
- Canvas: Fixed chords with chains which include sub chords in a group.
Celery now correctly executes the last task in these types of canvases:
.. code-block:: python
c = chord( group([ chain( dummy.si(), chord( group([dummy.si(), dummy.si()]), dummy.si(), ), ), chain( dummy.si(), chord( group([dummy.si(), dummy.si()]), dummy.si(), ), ), ]), dummy.si() ) c.delay().get()
Contributed by Maximilien Cuony
- Canvas: Complex canvases with error callbacks no longer raises an :class:
AttributeError
.
Very complex canvases such as
this <https://github.com/merchise/xopgi.base/blob/6634819ad5c701c04bc9baa5c527449070843b71/xopgi/xopgi_cdr/cdr_agent.py#L181>
_ no longer raise an :class:AttributeError
which prevents constructing them.We do not know why this bug occurs yet.
Contributed by Manuel Vรกzquez Acosta
- ๐ป Command Line: Added proper error messages in cases where app cannot be loaded.
Previously, celery crashed with an exception.
We now print a proper error message.
Contributed by Omer Katz
- Task: Added the :setting:
task_default_priority
setting.
You can now set the default priority of a task using the :setting:
task_default_priority
setting. The setting's value will be used if no priority is provided for a specific task.Contributed by :github_user:
madprogrammer
- Dependencies: Bump minimum required version of Kombu to 4.3 and Billiard to 3.6.
Contributed by Asif Saif Uddin
- Result Backend: Fix memory leak.
We reintroduced weak references to bound methods for AsyncResult callback promises, after adding full weakref support for Python 2 in
vine <https://github.com/celery/vine/tree/v1.2.0>
. More details can be found incelery/celery#4839 <https://github.com/celery/celery/pull/4839>
.Contributed by George Psarakis and :github_user:
monsterxx03
.- Task Execution: Fixed roundtrip serialization for eager tasks.
When doing the roundtrip serialization for eager tasks, the task serializer will always be JSON unless the
serializer
argument is present in the call to :meth:celery.app.task.Task.apply_async
. If the serializer argument is present but is'pickle'
, an exception will be raised as pickle-serialized objects cannot be deserialized without specifying toserialization.loads
what content types should be accepted. The Producer'sserializer
seems to be set toNone
, causing the default to JSON serialization.We now continue to use (in order) the
serializer
argument to :meth:celery.app.task.Task.apply_async
, if present, or theProducer
's serializer if notNone
. If theProducer
's serializer isNone
, it will use the Celery app'stask_serializer
configuration entry as the serializer.Contributed by Brett Jackson
- Redis Result Backend: The :class:
celery.backends.redis.ResultConsumer
class no longer assumes :meth:celery.backends.redis.ResultConsumer.start
to be called before :meth:celery.backends.redis.ResultConsumer.drain_events
.
This fixes a race condition when using the Gevent workers pool.
Contributed by Noam Kush
- Task: Added the :setting:
task_inherit_parent_priority
setting.
Setting the :setting:
task_inherit_parent_priority
configuration option toTrue
will make Celery tasks inherit the priority of the previous task linked to it.Examples:
.. code-block:: python
c = celery.chain( add.s(2), # priority=None add.s(3).set(priority=5), # priority=5 add.s(4), # priority=5 add.s(5).set(priority=3), # priority=3 add.s(6), # priority=3 )
.. code-block:: python
@app.task(bind=True) def child_task(self): pass @app.task(bind=True) def parent_task(self): child_task.delay() # child_task will also have priority=5 parent_task.apply_async(args=[], priority=5)
Contributed by :github_user:
madprogrammer
- Canvas: Added the :setting:
result_chord_join_timeout
setting.
Previously, :meth:
celery.result.GroupResult.join
had a fixed timeout of 3 seconds.The :setting:
result_chord_join_timeout
setting now allows you to change it.Contributed by :github_user:
srafehi
๐ท Code Cleanups, Test Coverage & CI Improvements by:
- Jon Dufresne
- Asif Saif Uddin
- Omer Katz
- Brett Jackson
- Bruno Alla
- :github_user:
tothegump
- Bojan Jovanovic
- Florian Chardin
- :github_user:
walterqian
- Fabian Becker
- Lars Rinn
- :github_user:
madprogrammer
- Ciaran Courtney
๐ Documentation Fixes by:
- Lewis M. Kabui
- Dash Winterson
- Shanavas M
- Brett Randall
- Przemysลaw Suliga
- Joshua Schmid
- Asif Saif Uddin
- Xiaodong
- Vikas Prasad
- Jamie Alessio
- Lars Kruse
- Guilherme Caminha
- Andrea Rabbaglietti
- Itay Bittan
- Noah Hall
- Peng Weikang
- Mariatta Wijaya
- Ed Morley
- Paweล Adamczak
- :github_user:
CoffeeExpress
- :github_user:
aviadatsnyk
- Brian Schrader
- Josue Balandrano Coronel
- Tom Clancy
- Sebastian Wojciechowski
- Meysam Azad
- Willem Thiart
- Charles Chan
- Omer Katz
- Milind Shakya
- Canvas: :meth: