Celery

Latest version: v5.3.6

Safety actively analyzes 613682 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 12 of 48

4.0

===
:release-date: 2016-10-28 16:45 P.M UTC
:release-by: Ask Solem

- Now depends on :mod:`amqp` 2.0.

The new py-amqp version have been refactored for better performance,
using modern Python socket conventions, and API consistency.

- No longer depends on :mod:`anyjson`.

Kombu will now only choose between :pypi:`simplejson` and the built-in
:mod:`json`.

Using the latest version of simplejson is recommended:

.. code-block:: console

$ pip install -U simplejson

- Removed transports that are no longer supported in this version:

- Django ORM transport
- SQLAlchemy ORM transport
- Beanstalk transport
- ZeroMQ transport
- amqplib transport (use pyamqp).

- API Changes

* Signature of :class:`kombu.Message` now takes body as first argment.

It used to be ``Message(channel, body=body, **kw)``, but now it's
``Message(body, channel=channel, **kw)``.

This is unlikey to affect you, as the Kombu API does not have
users instantiate messages manually.

- New SQS transport

Donated by NextDoor, with additional contributions from mdk.

.. note::

``kombu[sqs]`` now depends on :pypi:`pycurl`.

- New Consul transport.

Contributed by **Wido den Hollander**.

- New etcd transport.

Contributed by **Stephen Milner**.

- New Qpid transport.

It was introduced as an experimental transport in Kombu 3.0, but is now
mature enough to be fully supported.

Created and maintained by **Brian Bouterse**.

- Redis: Priority 0 is now lowest, 9 is highest.
(**backward incompatible**)

This to match how priorities in AMQP works.

Fix contributed by **Alex Koshelev**.

- Redis: Support for Sentinel

You can point the connection to a list of sentinel URLs like:

.. code-block:: text

sentinel://0.0.0.0:26379;sentinel://0.0.0.0:26380/...

where each sentinel is separated by a `;`. Multiple sentinels are handled
by :class:`kombu.Connection` constructor, and placed in the alternative
list of servers to connect to in case of connection failure.

Contributed by **Sergey Azovskov**, and **Lorenzo Mancini**

- RabbitMQ Queue Extensions

New arguments have been added to :class:`kombu.Queue` that lets
you directly and conveniently configure the RabbitMQ queue extensions.

- ``Queue(expires=20.0)``

Set queue expiry time in float seconds.

See :attr:`kombu.Queue.expires`.

- ``Queue(message_ttl=30.0)``

Set queue message time-to-live float seconds.

See :attr:`kombu.Queue.message_ttl`.

- ``Queue(max_length=1000)``

Set queue max length (number of messages) as int.

See :attr:`kombu.Queue.max_length`.

- ``Queue(max_length_bytes=1000)``

Set queue max length (message size total in bytes) as int.

See :attr:`kombu.Queue.max_length_bytes`.

- ``Queue(max_priority=10)``

Declare queue to be a priority queue that routes messages
based on the ``priority`` field of the message.

See :attr:`kombu.Queue.max_priority`.

- RabbitMQ: ``Message.ack`` now supports the ``multiple`` argument.

If multiple is set to True, then all messages received before
the message being acked will also be acknowledged.

- ``amqps://`` can now be specified to require SSL (Issue 610).

- ``Consumer.cancel_by_queue`` is now constant time.

- ``Connection.ensure*`` now raises :exc:`kombu.exceptions.OperationalError`.

Things that can be retried are now reraised as
:exc:`kombu.exceptions.OperationalError`.

- Redis: Fixed SSL support.

Contributed by **Robert Kolba**.

- New ``Queue.consumer_arguments`` can be used for the ability to
set consumer priority via ``x-priority``.

See https://www.rabbitmq.com/consumer-priority.html

Example:

.. code-block:: python

Queue(
'qname',
exchange=Exchange('exchange'),
routing_key='qname',
consumer_arguments={'x-priority': 3},
)

- Queue/Exchange: ``no_declare`` option added (also enabled for
internal amq. exchanges) (Issue 565).

- JSON serializer now calls ``obj.__json__`` for unsupported types.

This means you can now define a ``__json__`` method for custom
types that can be reduced down to a built-in json type.

Example:

.. code-block:: python

class Person:
first_name = None
last_name = None
address = None

def __json__(self):
return {
'first_name': self.first_name,
'last_name': self.last_name,
'address': self.address,
}

- JSON serializer now handles datetimes, Django promise, UUID and Decimal.

- Beanstalk: Priority 0 is now lowest, 9 is highest.
(**backward incompatible**)

This to match how priorities in AMQP works.

Fix contributed by **Alex Koshelev**.

- Redis: now supports SSL using the ``ssl`` argument to
:class:`~kombu.Connection`.

- Redis: Fanout exchanges are no longer visible between vhosts,
and fanout messages can be filtered by patterns.
(**backward incompatible**)

It was possible to enable this mode previously using the
``fanout_prefix``, and ``fanout_patterns``
transport options, but now these are enabled by default.

If you want to mix and match producers/consumers running different
versions you need to configure your kombu 3.x clients to also enable
these options:

.. code-block:: pycon

>>> Connection(transport_options={
'fanout_prefix': True,
'fanout_patterns': True,
})

- Pidbox: Mailbox new arguments: TTL and expiry.

Mailbox now supports new arguments for controlling
message TTLs and queue expiry, both for the mailbox
queue and for reply queues.

- ``queue_expires`` (float/int seconds).
- ``queue_ttl`` (float/int seconds).
- ``reply_queue_expires`` (float/int seconds).
- ``reply_queue_ttl`` (float/int seconds).

All take seconds in int/float.

Contributed by **Alan Justino**.

- Exchange.delivery_mode now defaults to :const:`None`, and the default
is instead set by ``Producer.publish``.

- :class:`~kombu.Consumer` now supports a new ``prefetch_count`` argument,
which if provided will force the consumer to set an initial prefetch count
just before starting.

- Virtual transports now stores ``priority`` as a property, not in
``delivery_info``, to be compatible with AMQP.

- ``reply_to`` argument to ``Producer.publish`` can now be
:class:`~kombu.Queue` instance.

- Connection: There's now a new method
``Connection.supports_exchange_type(type)`` that can be used to check if the
current transport supports a specific exchange type.

- SQS: Consumers can now read json messages not sent by Kombu.

Contributed by **Juan Carlos Ferrer**.

- SQS: Will now log the access key used when authentication fails.

Contributed by **Hank John**.

- Added new :class:`kombu.mixins.ConsumerProducerMixin` for consumers that
will also publish messages on a separate connection.

- Messages: Now have a more descriptive ``repr``.

Contributed by **Joshua Harlow**.

- Async: HTTP client based on curl.

- Async: Now uses `poll` instead of `select` where available.

- MongoDB: Now supports priorities

Contributed by **Alex Koshelev**.

- Virtual transports now supports multiple queue bindings.

Contributed by **Federico Ficarelli**.

- Virtual transports now supports the anon exchange.

If when publishing a message, the exchange argument is set to '' (empty
string), the routing_key will be regarded as the destination queue.

This will bypass the routing table compeltely, and just deliver the
message to the queue name specified in the routing key.

- Zookeeper: Transport now uses the built-in suport in kazoo to handle
failover when using a list of server names.

Contributed by **Joshua Harlow**.

- ConsumerMixin.run now passes keyword arguments to .consume.

Deprecations and removals
-------------------------

- The deprecated method ``Consumer.add_queue_from_dict`` has been removed.

Use instead:

.. code-block:: python

consumer.add_queue(Queue.from_dict(queue_name, **options))

- The deprecated function ``kombu.serialization.encode`` has been removed.

Use :func:`kombu.serialization.dumps` instead.

- The deprecated function ``kombu.serialization.decode`` has been removed.

Use :func:`kombu.serialization.loads` instead.

- Removed module ``kombu.syn``

``detect_environment`` has been moved to kombu.utils.compat

.. _version-3.0.37:

4.0.0

Not secure
--------------------
- Support Sphinx 4.x.
- Remove dependency to case.
- Drop support of Python < 3.7.
- Update to psutil 5.9.0.
- Add python_requires to enforce Python version.
- Replace deprecated threading Event.isSet with Event.is_set.
- Prevent segmentation fault in get_pdeathsig while using ctypes (361).
- Migrated CI to Github actions.
- Python 3.10 support added.

3.6.4.0

--------------------
- Issue 309: Add Python 3.9 support to spawnv_passfds()
- fix 314

3.6.1

--------------------

- Logging max memory reached at INFO rather than WARNING (255)

- Pass arguments when wrapping sys.exit (275)

- Remove win32/py2k special (276)

- Ensure READY messages sent out by exiting worker are consumed prior to it actually existing.

- Pass max_memory_per_child to child worker process (251)

- Fix compatibility with Python 2.7 on Windows (283)

3.6.0.0

--------------------

- Add support of sending parent process death signal.

- Previous fix for handling timeouts caused a problem in warm shutdowns due
to use of deepcopy.

We now use a shallow copy of the cache and do so only when it is needed.

- Cleanup old checks and workarounds for Python versions we no longer support.

3.5.0.5

--------------------

- Fix a crash when handling a timeout.
- Improve billiard.einfo.Frame compatibility with Python to avoid crashes when using Django.
- Cleanups.

Page 12 of 48

Links

Releases

Has known vulnerabilities

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.