summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* python !=3.12.1pinmongoAsif Saif Uddin2021-11-081-1/+1
|
* add python 3.10 to classifierAsif Saif Uddin2021-11-061-1/+2
|
* Bump redis version to >= 3.4.1Matus Valo2021-11-061-1/+1
|
* Added integration test of failed authentication to redisMatus Valo2021-11-061-2/+22
|
* Add PR number to Changelog.rstMatus Valo2021-11-031-1/+1
|
* Quick fix: current version is 5.2.0, not 5.2.01v5.2.0Naomi Elstein2021-11-023-6/+6
|
* Bump version: 5.2.0rc1 → 5.2.0Naomi Elstein2021-11-024-4/+4
|
* 5.2.0 release notes (#1417)Naomi Elstein2021-11-021-2/+35
| | | | | * Add changelog for version 5.2.0 release * Fix anchors for versions 5.2.0rc1, 5.1.0
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2021-10-251-1/+1
| | | | | updates: - [github.com/asottile/yesqa: v1.2.3 → v1.3.0](https://github.com/asottile/yesqa/compare/v1.2.3...v1.3.0)
* Return empty list instead of InconsistencyError when exchange table is emptyMatus Valo2021-10-253-14/+27
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Missing redis key containg set of queues bound to queue is caused by removal all queues from the exchange. Hence, we should not raise an exception but just return empty list of queues instead. This commit fixes e.g. case publishing message against empty exchange: import kombu conn = kombu.Connection('redis://') exchange = kombu.Exchange('name', type='direct') exchange.declare(channel=conn.default_channel) producer = conn.Producer() producer.publish( {'hello': 'world'}, exchange=exchange, routing_key='queue1' ) But it also fixes the case when last queue is unbound from exchange and after publishing to this exchange: import kombu conn = kombu.Connection('redis://') exchange = kombu.Exchange('name', type='direct') queue1 = kombu.Queue('queue1', exchange=exchange, routing_key='queue1') exchange.declare(channel=conn.default_channel) queue1 = queue1.bind(channel=conn.default_channel) queue1.declare() producer = conn.Producer() producer.publish( {'hello': 'world'}, exchange=exchange, routing_key='queue1' ) queue1.delete() producer.publish( {'hello': 'world'}, exchange=exchange, routing_key='queue1' )
* Dont failfast when pypy3 tests fail (#1408)Matus Valo2021-10-241-1/+7
|
* try to fix CI (#1407)Asif Saif Uddin2021-10-231-6/+6
| | | | | * try to fix CI * try without py310
* add python 3.10 to CI & fix other issues (#1402)Asif Saif Uddin2021-10-231-9/+10
| | | | | * add python 3.10 to CI & fix other issues * try pypy3.7
* removre bdistAsif Saif Uddin2021-10-231-3/+0
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2021-10-121-1/+1
| | | | | updates: - [github.com/PyCQA/flake8: 3.9.2 → 4.0.1](https://github.com/PyCQA/flake8/compare/3.9.2...4.0.1)
* Fix test_pidbox unittests to support non-linux platforms (#1398)Matus Valo2021-10-051-5/+1
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2021-10-051-1/+1
| | | | | updates: - [github.com/asottile/pyupgrade: v2.28.0 → v2.29.0](https://github.com/asottile/pyupgrade/compare/v2.28.0...v2.29.0)
* fix flake8 in kombu/asynchronous/aws/connection.py (#1397)Matus Valo2021-10-052-2/+2
| | | | | | | | | * fix flake8 in kombu/asynchronous/aws/connection.py * [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>
* Added unittests for #1394Matus Valo2021-10-051-0/+40
|
* Prevent caching of oid in pidbox (#1394)Matus Valo2021-10-051-8/+2
| | | | | | | | | | | | oid is not cached anymore due race conditions of oid in celery. Caching oid is causing following exception: OperationalError(" Cannot route message for exchange 'reply.celery.pidbox': Table empty or key no longer exists. Probably the key ('_kombu.binding.reply.celery.pidbox') has been removed from the Redis database. ",) This exception seems to be occuring when multiple celery workers contains same oid.
* py3.7+ on setup (#1392)Asif Saif Uddin2021-09-271-2/+1
|
* [pre-commit.ci] pre-commit autoupdate (#1393)pre-commit-ci[bot]2021-09-279-13/+12
| | | | | | | | | | | | * [pre-commit.ci] pre-commit autoupdate updates: - [github.com/asottile/pyupgrade: v2.26.0 → v2.28.0](https://github.com/asottile/pyupgrade/compare/v2.26.0...v2.28.0) * [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>
* Fix: check redis response typekaiix2021-09-162-1/+7
|
* Remove dependency to case (#1389)Matus Valo2021-09-1513-87/+343
| | | | | | | | | | | | | * Remove dependency to case * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci * Fix flake8 errors * Remove unused code Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2021-09-141-1/+1
| | | | | updates: - [github.com/asottile/pyupgrade: v2.25.0 → v2.26.0](https://github.com/asottile/pyupgrade/compare/v2.25.0...v2.26.0)
* Fix missing dependency to redis in docs requirementsMatus Valo2021-09-121-0/+1
|
* Use ANY from unittest instead of case.mockMatus Valo2021-09-121-2/+2
|
* drop python 3.6 from CI (#1382)Asif Saif Uddin2021-09-092-10/+9
| | | | | | | * drop python 3.6 from CI * Drop 3.6 from CI matrix. Co-authored-by: Omer Katz <omer.drow@gmail.com>
* test new pytest version (#1383)Asif Saif Uddin2021-09-081-1/+1
|
* Merge branch 'master' of https://github.com/celery/kombuAsif Saif Uddin2021-09-072-10/+2
|\
| * stop mentioning librabbitmq (#1381)Asif Saif Uddin2021-09-071-9/+1
| |
| * v 1.4.x (#1338)Asif Saif Uddin2021-09-071-1/+1
| | | | | | | | | | * v 1.4.x
* | Bump version: 5.1.0 → 5.2.0rc1v5.2.0rc1Asif Saif Uddin2021-09-074-4/+4
| |
* | update changelog for v5.2.0rc1Asif Saif Uddin2021-09-071-0/+20
|/
* [pre-commit.ci] pre-commit autoupdate (#1379)pre-commit-ci[bot]2021-08-311-1/+1
| | | | | | updates: - [github.com/asottile/pyupgrade: v2.24.0 → v2.25.0](https://github.com/asottile/pyupgrade/compare/v2.24.0...v2.25.0) Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
* Run integration tests for kombu also with global_keyprefixMatus Valo2021-08-311-3/+5
|
* Make BrokerState Transport specificMatus Valo2021-08-305-6/+26
|
* fix: add missing commands to prefixGábor Boros2021-08-272-4/+20
| | | | | | Add missing DEL, RPUSH, RPOP and SREM commands to the list of commands to prefix. Also, this commit refactors the prefixing logic a bit to make it simpler.
* fix: raise BrokenPipeError (#1231)Steven2021-08-261-0/+4
| | | | Co-authored-by: Steven Joseph <steven@pointzi.com> Co-authored-by: Steven Joseph <steven@stevenjoseph.in>
* Add global key prefix for keys set by Redis transporter (#1349)Gábor Boros2021-08-253-2/+218
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * Introduce global key prefix for redis transport Co-authored-by: Matus Valo <matusvalo@users.noreply.github.com> * refactor: use a custom redis client As per the suggestions, refactor the redis key prefixing to use a custom redis client that prefixes the keys it uses. The custom client implementation does not prefix every key by default as the way of prefixing keys may differ for some redis commands, instead it lists those keys that will be prefixed. In case of commands, where multiple keys can be passed as an argument, the custom client defines where the arg positions are starting and ending for the given command. * test: fix unit tests by moving import statement * fix: wrap redis.parse_response to remove key prefixes Co-authored-by: Matus Valo <matusvalo@users.noreply.github.com> * fix: typo * fix: lint Co-authored-by: Antonin Delpeuch <antonin@delpeuch.eu> Co-authored-by: Matus Valo <matusvalo@users.noreply.github.com> Co-authored-by: Jillian Vogel <jill@opencraft.com>
* [pre-commit.ci] pre-commit autoupdate (#1374)pre-commit-ci[bot]2021-08-241-1/+1
| | | | | | updates: - [github.com/asottile/pyupgrade: v2.23.3 → v2.24.0](https://github.com/asottile/pyupgrade/compare/v2.23.3...v2.24.0) Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
* SQS Channel.predefined_queues should be `{}` if not definedBrad Smith2021-08-212-1/+19
| | | | Previously, calling `reject` when `predefined_queues` was not configured would cause `AttributeError` to be raised from `_extract_backoff_policy_configuration_and_message`. That exception could crash the whole Celery worker and force it to exit early because `AttributeError` is not excepted in the nearby call stack.
* Fixed type commentSchizmOne2021-08-211-2/+2
|
* Use Python's built-in json module by default, instead of simplejsonnikolas2021-08-141-6/+6
| | | Only use simplejson if it's absolutely necessary - Python's built-in json module is better if it's available.
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2021-08-101-1/+1
| | | | | updates: - [github.com/asottile/pyupgrade: v2.23.1 → v2.23.3](https://github.com/asottile/pyupgrade/compare/v2.23.1...v2.23.3)
* [pre-commit.ci] auto fixes from pre-commit.com hookspre-commit-ci[bot]2021-08-051-2/+2
| | | | for more information, see https://pre-commit.ci
* Use hostname from URI when server_host is NoneMatus Valo2021-08-053-2/+84
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2021-08-031-2/+2
| | | | | | updates: - [github.com/asottile/pyupgrade: v2.23.0 → v2.23.1](https://github.com/asottile/pyupgrade/compare/v2.23.0...v2.23.1) - [github.com/pycqa/isort: 5.9.2 → 5.9.3](https://github.com/pycqa/isort/compare/5.9.2...5.9.3)
* Add support for Python 3.9Michał Bielawski2021-07-313-11/+13
|
* [pre-commit.ci] pre-commit autoupdate (#1359)pre-commit-ci[bot]2021-07-291-2/+2
| | | | | | | updates: - [github.com/asottile/pyupgrade: v2.21.2 → v2.23.0](https://github.com/asottile/pyupgrade/compare/v2.21.2...v2.23.0) - https://gitlab.com/pycqa/flake8 → https://github.com/PyCQA/flake8 Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
View Lorry Controller Status