Commit Graph

61 Commits

Author SHA1 Message Date
Paul Rysiavets 07c8852be5
Feature: urllib3 instead of curl (#2134)
* feature(urllib3): add urllib3 client

* test(urllib3): test urllib3 client

* test(urllib3): update http test for urllib3

* test(urllib3): use urllib3 client instead of curl

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* style(urllib3): remove unused imports

* style(urllib3): fix pre-commit errors

* ci(urllib3): remove pycurl dependency

* docs(urllib3): add docs

* style(urllib3): fix failing gh-workflow py3.8

* style(urllib3): add mention of ProxyManager

* style(urllib3): fix pre-commit issues

* style(pycurl): remove curl-related code

* feat(urllib3): add missing request features (header, auth, ssl, proxy, redirects)

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* fix(urllib3): improve styling

* test(urllib3): add new tests

* fix(urllib3): fix request auth

* fix(aws): validate certificate on request

* style(): add missing exports

* feat(aws): add ssl certificate verification from boto

* feat(urllib): try to use certifi.where() if request.ca_certs are not provided

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* ci(pydocstyle): add missing docstring in public class

* test(urllib3): improve test case

* ci(pydocstyle): fix multi-line docstring summary should start at the first line

* feat(urllib3): remove assert_hostname

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

* test(boto): add test for get_cert_path returning .pem file path

* test(urllib3): add test for _get_pool_key_parts method

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

---------

Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
Co-authored-by: Asif Saif Uddin <auvipy@gmail.com>
Co-authored-by: Tomer Nosrati <tomer.nosrati@gmail.com>
2024-10-14 17:01:25 +06:00
Omer Katz 5a88a28f31
Add native delayed delivery API to kombu (#2128)
* Adjust flake8 configuration to match Celery's configuration.

* Add native delayed delivery API.

* Add documentation.

* Fix linter errors.

* Fix pydocstyle errors.

* Fix apicheck linter.

* Address code review.
2024-10-12 21:17:55 +03:00
Matus Valo 7b989d64b7
Reformat and improve kombu transport reference docs (#1264) 2020-11-03 22:41:22 +01:00
Matus Valo 5620904c75 Split reference guide into sections 2020-10-08 20:10:00 +02:00
Matus Valo 01719be0b8 Removed kombu.five from reference toctree 2020-09-27 21:33:51 +02:00
Jason Held 41dbbe3063 Control pattern matching (#997)
* 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.
2019-02-27 20:23:12 +06:00
Clemens Wolff 32633554ac Add transports based on Azure PaaS (#891)
* 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
2018-08-30 23:34:52 +06:00
Thomas Achtemichuk 75695205f6 Rename `async` keyword to `asynchronous` (#839)
* 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
2018-03-19 19:28:43 +02:00
Amin Ghadersohi be79b3d4cd Re-Adding support for sqlalchemy as it is needed by Apache project Airflow (#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
2017-05-17 14:17:47 +06:00
Ask Solem 5d91ef3dbe Doc fixes 2016-10-27 16:15:40 -07:00
Ask Solem 95e4c9ab21 Adds kombu.utils.time to API Reference 2016-10-14 17:01:45 -07:00
Ask Solem 03790d3afc Removes kombu.syn, moves detect_environment to utils.compat 2016-10-05 16:14:42 -07:00
Ask Solem 85c191a48a Reorganizes kombu.utils.__init__ package 2016-07-16 13:34:08 -07:00
Ask Solem 87a5568bc8 Use Google-style docstrings 2016-07-16 11:51:23 -07:00
Ask Solem e4189c0c95 Removes deprecated amqplib transport (replaced by py-amqp) 2016-06-28 15:52:49 -07:00
Ask Solem 5f817ff1f9 Removes ZeroMQ transport for lack of resources to support it. 2016-06-28 15:48:09 -07:00
Ask Solem 5f3ae92708 Removes Beanstalk transport for lack of resources to support it 2016-06-28 15:45:30 -07:00
Ask Solem d06248ebaa Removes CouchDB transport for lack of resources to maintain it. 2016-06-28 15:41:54 -07:00
Ask Solem 65f982ccf3 Removes Django ORM as a broker support 2016-06-27 19:31:01 -07:00
Ask Solem 1cd4e07f9e Removes SQLAlchemy as a broker support 2016-06-27 19:26:44 -07:00
Ask Solem a25b77756c [dist] Use apicheck from sphinx_celery 2016-04-08 15:06:19 -07:00
Ask Solem a8203aee1f [requirements][docs] Now depends on Sphinx 1.4 2016-04-07 11:46:09 -07:00
Brian Bouterse c569d35c30 Merge branch 'master' into qpid-transport 2014-06-11 09:21:03 -04:00
Ask Solem 19c83a1b52 Merge branch '3.0'
Conflicts:
	README.rst
	kombu/__init__.py
	kombu/async/hub.py
	kombu/utils/url.py
2014-06-02 17:20:32 +01:00
Ask Solem 202e5b56e8 Fixes typo in reference index 2014-06-02 17:18:32 +01:00
Brian Bouterse 95c729b3f2 Merge branch 'master' into qpid-transport
Conflicts:
	README.rst
	docs/userguide/connections.rst
2014-05-28 10:05:56 -04:00
Ask Solem f80e0c349f Removes kombu.utils.compat.get_errno 2014-05-21 12:57:24 +01:00
Brian Bouterse 05d94c4683 Adding reference .rst files 2014-03-17 17:11:53 -04:00
Ask Solem 0dd1ccdb17 Adds missing reference page 2014-03-03 16:20:41 +00:00
Ask Solem 61c14b22f5 Adds kombu.async.timer (+ accidentally staged documentation fixes) 2013-10-01 17:30:26 +01:00
Ask Solem e5cb2e19e8 Adds missing reference pages 2013-09-12 17:32:19 +01:00
Ask Solem 34589403e5 Merge branch '2.5'
Conflicts:
	README.rst
	kombu/__init__.py
	kombu/transport/__init__.py
	requirements/default.txt
2013-04-02 15:02:39 +01:00
Ask Solem 0e5ece66d5 Use fuzzy matching to suggest alternatives to typos in transport name 2013-03-22 12:39:43 +00:00
Ask Solem f68f8ac8c0 Merge branch 'master' into 3.0
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
2012-11-27 15:48:42 +00:00
Ask Solem c16e0822a3 Doc fixes 2012-11-21 17:34:04 +00:00
Ask Solem 9cc13cebe1 Removes pika transport, will wait until pika comes out of experimental its state 2012-11-15 16:05:37 +00:00
Ask Solem a4a2d483fe Removes kombu.utils.finalize: Use multiprocessing.util.Finalize instead 2012-11-13 13:56:02 +00:00
Ask Solem aa0323e398 py-amqp replaces amqplib as the default transport 2012-11-05 13:27:07 +00:00
Ask Solem 9c190595f9 Refs to kombu top level symbols now resolve, and there's a kombu reference page 2012-10-23 16:24:39 +01:00
Ask Solem f82ac71a41 Adds autodoc for kombu.transport.zmq 2012-08-17 19:47:08 +01:00
Ask Solem 72d9b1c177 Adds reference API for kombu.transport.pyamqp 2012-07-24 16:21:42 +01:00
Ask Solem 8c034338ca Adds missing reference pages 2012-07-05 15:47:12 +01:00
Mahendra M c43eb27700 Adds support for Apache Zookeeper as a transport.
Closes #134
2012-06-07 15:06:24 +01:00
Ask Solem b40fa572be Adds kombu.utils.url to API reference 2012-04-03 16:19:02 +01:00
Ask Solem 8507bd8dff Cosmetics 2012-01-15 18:35:21 +00:00
Ask Solem dd7808f97b Adds missing reference files 2012-01-09 16:50:12 +00:00
Ask Solem c0383c88f5 PEP8ify + pyflakes 2011-09-22 17:10:13 +01:00
Ask Solem 729988f2ab Adds missing reference pages 2011-09-07 14:13:11 +01:00
Ask Solem c60f02c994 Fixes Sphinx errors 2011-09-05 13:09:39 +01:00
Ask Solem f5274e4aac Adds missing reference for kombu.utils.encoding 2011-09-05 12:59:26 +01:00