| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Added pattern/matcher to Mailbox
* pattern/match for kombu 4
* Ensure kombu.matcher is covered by our documentation.
* Adds test_matcher & pidbox unit tests.
* Added tests to ensure exception is raised when matcher is not registered.
* Adds to test for destination passed in to process.
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
| |
broker daemon (#895)
* Make the pyro transport available and fix it for recent Pyro4 version.
Implemented the missing Pyro Kombu broker to actually be able to use the Pyro transport
* code style
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Add transports based on Azure PaaS
This pull request adds two new transport implementations:
- `azurestoragequeues` is implemented on top of Azure Storage
Queues [1]. This offers a simple but scalable and low-cost PaaS
transport for Celery users in Azure. The transport is intended to be
used in conjunction with the Azure Block Blob Storage backend [2].
- `azureservicebus` is implemented on top of Azure Service Bus [3] and
offers PaaS support for more demanding Celery workloads in Azure. The
transport is intended to be used in conjunction with the Azure
CosmosDB backend [4].
This pull request was created together with @ankurokok, @dkisselev,
@evandropaula, @martinpeck and @michaelperel.
[1] https://azure.microsoft.com/en-us/services/storage/queues/
[2] https://github.com/celery/celery/pull/4685
[3] https://azure.microsoft.com/en-us/services/service-bus/
[4] https://github.com/celery/celery/pull/4720
* Exclude Azure transports from code coverage
There is test coverage for the transports but the tests require Azure
credentials to run (passed via environment variables) so codecov doesn't
exercise them.
* Remove env vars to configure transport
* Remove abbreviations
|
| |
|
|
|
| |
For details on the new PyPI, see the blog post:
https://pythoninsider.blogspot.ca/2018/04/new-pypi-launched-legacy-pypi-shutting.html
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Rename `async` keyword to `asynchronous`
* Fixes #742
* Resolves "DeprecationWarning: 'async' and 'await' will become reserved
keywords in Python 3.7"
* Address PR feedback
* Update appveyor config
* Rename docs and tests
|
| | |
|
| |
|
|
|
|
|
|
| |
(#687)
* Re-Adding support for sqlalchemy as it is needed by Apache project Airflow
* Re-Adding support for sqlalchemy as it is needed by Apache project Airflow
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
|
|
| |
This transport is highly influenced by the Consul Transport.
Messages are kept in keys within Etcd through the python-etcd library.
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
| |
Using the Key/Value store of Consul.io this commit adds a new
Transport.
It is a simple Transport which Messages as Keys in the K/V store
of Consul using the HTTP API.
The HTTP API is consumed using the python-consul client which exposes
the API in a Python way.
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Order in which we consume from queues.
Can be either string alias, or a cycle strategy class
- ``round_robin``
:class:`~kombu.utils.scheduling.round_robin_cycle``
Make sure each queue has an equal opportunity to be consumed from.
- ``sorted``
:class:`~kombu.utils.scheduling.sorted_cycle`.
Consume from queues in alphabetical order.
If the first queue in the sorted list always contains messages,
then the rest of the queues will never be consumed from.
- ``priority``
:class:`~kombu.utils.scheduling.priority_cycle`.
Consume from queues in original order, so that if the first
queue always contains messages, the rest of the queues
in the list will never be consumed from.
The default is to consume from queues in round robin.
|
| | |
|
| |\ |
|
| | |\
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
Conflicts:
README.rst
kombu/__init__.py
kombu/async/hub.py
kombu/utils/url.py
|
| | | | |
|
| |\ \ \
| |/ /
| | |
| | |
| | |
| | | |
Conflicts:
README.rst
docs/userguide/connections.rst
|
| | |/ |
|
| | | |
|
| |/ |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| |\
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
Conflicts:
Changelog
README.rst
kombu/__init__.py
kombu/messaging.py
kombu/serialization.py
kombu/transport/redis.py
requirements/default.txt
|
| | | |
|
| |\ \
| |/
| |
| |
| |
| |
| |
| | |
Conflicts:
README.rst
kombu/__init__.py
kombu/transport/__init__.py
requirements/default.txt
|
| | | |
|
| | | |
|
| |\ \
| |/
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
Conflicts:
kombu/abstract.py
kombu/clocks.py
kombu/messaging.py
kombu/pidbox.py
kombu/pools.py
kombu/tests/mocks.py
kombu/tests/test_common.py
kombu/tests/test_messaging.py
kombu/tests/test_serialization.py
kombu/tests/test_utils.py
kombu/tests/transport/test_redis.py
kombu/tests/utilities/test_encoding.py
kombu/transport/pika.py
kombu/transport/zmq.py
kombu/transport/zookeeper.py
kombu/utils/__init__.py
kombu/utils/encoding.py
kombu/utils/finalize.py
pavement.py
requirements/default.txt
|
| | | |
|