Celery

Latest version: v5.4.0

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

Scan your dependencies

Page 40 of 48

1.4.0

=====
:release-date: 2011-09-22 05:00 P.M BST
:release-by: Ask Solem

* Adds module :mod:`kombu.mixins`.

This module contains a :class:`~kombu.mixins.ConsumerMixin` class
that can be used to easily implement a message consumer
thread that consumes messages from one or more
:class:`kombu.Consumer` instances.

* New example: :ref:`task-queue-example`

Using the ``ConsumerMixin``, default channels and
the global connection pool to demonstrate new Kombu features.

* MongoDB transport did not work with MongoDB >= 2.0 (Issue 66)

Fix contributed by James Turk.

* Redis-py version check did not account for beta identifiers
in version string.

Fix contributed by David Ziegler.

* Producer and Consumer now accepts a connection instance as the
first argument.

The connections default channel will then be used.

In addition shortcut methods has been added to Connection:

.. code-block:: pycon

>>> connection.Producer(exchange)
>>> connection.Consumer(queues=..., callbacks=...)

* Connection has aquired a ``connected`` attribute that
can be used to check if the connection instance has established
a connection.

* ``ConnectionPool.acquire_channel`` now returns the connections
default channel rather than establising a new channel that
must be manually handled.

* Added ``kombu.common.maybe_declare``

``maybe_declare(entity)`` declares an entity if it has
not previously been declared in the same process.

* :func:`kombu.compat.entry_to_queue` has been moved to :mod:`kombu.common`

* New module :mod:`kombu.clocks` now contains an implementation
of Lamports logical clock.

.. _version-1.3.5:

1.3.5

=====
:release-date: 2011-09-16 06:00 P.M BST
:release-by: Ask Solem

* Python 3: AMQP_PROTOCOL_HEADER must be bytes, not str.

.. _version-1.3.4:

1.3.4

=====
:release-date: 2011-09-16 06:00 P.M BST
:release-by: Ask Solem

* Fixes syntax error in pools.reset


.. _version-1.3.3:

1.3.3

=====
:release-date: 2011-09-15 02:00 P.M BST
:release-by: Ask Solem

* pools.reset did not support after forker arguments.

.. _version-1.3.2:

1.3.2

=====
:release-date: 2011-09-10 01:00 P.M BST
:release-by: Mher Movsisyan

* Broke Python 2.5 compatibility by importing ``parse_qsl`` from ``urlparse``

* Connection.default_channel is now closed when connection is revived
after connection failures.

* Pika: Channel now supports the ``connection.client`` attribute
as required by the simple interface.

* pools.set_limit now raises an exception if the limit is lower
than the previous limit.

* pools.set_limit no longer resets the pools.

.. _version-1.3.1:

1.3.1

=====
:release-date: 2011-10-07 03:00 P.M BST
:release-by: Ask Solem

* Last release broke after fork for pool reinitialization.

* Producer/Consumer now has a ``connection`` attribute,
giving access to the :class:`Connection` of the
instance.

* Pika: Channels now have access to the underlying
:class:`Connection` instance using ``channel.connection.client``.

This was previously required by the ``Simple`` classes and is now
also required by :class:`Consumer` and :class:`Producer`.

* Connection.default_channel is now closed at object revival.

* Adds kombu.clocks.LamportClock.

* compat.entry_to_queue has been moved to new module :mod:`kombu.common`.

.. _version-1.3.0:

Page 40 of 48

Links

Releases

Has known vulnerabilities

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.