summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* 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>
* enable pre-commit (#1355)Thomas Grainger2021-07-20119-442/+407
| | | | | | | | | | | | | | | | | | | * enable pre-commit * use extend-ignore for flake8 * manual flake8 fixes * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci * Update kombu/__init__.py Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
* Update docstrings of redis transport with user and passwordMatus Valo2021-07-081-3/+3
|
* Add support for setting redis username (#1351)Gábor Boros2021-07-082-3/+17
| | | | | * feat: add support for setting redis username * tests: add redis connparams credentials tests
* Move pytest.importorskip to run earlier (#1346)Felix Yan2021-06-111-4/+3
| | | | | | | | | | | | | | | | | | | | | | * Move pytest.importorskip to run earlier Currently pytest fails to collect tests when `azure` is not present. Moving the pytest.importorskip clause before `from kombu.transport import azureservicebus` fixes it. ``` ==================================== ERRORS ==================================== __________ ERROR collecting t/unit/transport/test_azureservicebus.py ___________ ImportError while importing test module '/build/python-kombu/src/kombu-5.1.0/t/unit/transport/test_azureservicebus.py'. Hint: make sure your test modules/packages have valid Python names. Traceback: /usr/lib/python3.9/importlib/__init__.py:127: in import_module return _bootstrap._gcd_import(name[level:], package, level) t/unit/transport/test_azureservicebus.py:12: in <module> from kombu.transport import azureservicebus kombu/transport/azureservicebus.py:66: in <module> import azure.core.exceptions E ModuleNotFoundError: No module named 'azure' ``` * Add # noqa to make linter happy
* Make flake8 happyMatus Valo2021-06-091-5/+10
|
* Small fixes in documentationMatus Valo2021-06-092-12/+6
|
* Small fixes in documentationMatus Valo2021-06-093-1/+3
|
* fix typoAsif Saif Uddin2021-05-261-1/+1
|
* Remove backward compatible code not used anymore (#1344)Matus Valo2021-05-256-67/+23
| | | | | * Fix broken nested() after #1320 * Remove backward compatible code not needed anymore
* Fix version replacement.Omer Katz2021-05-231-1/+1
|
* Bump version: 5.1.0b1 → 5.1.0Omer Katz2021-05-234-4/+4
|
* Update release notes.Omer Katz2021-05-231-0/+11
|
* prepare_accept_content() now raises SerializerNotInstalled instead of ↵Matus Valo2021-05-232-2/+21
| | | | | | | KeyError (#1343) * Fix broken nested() after #1320 * prepare_accept_content now raises SerializerNotInstalled when wrong serializer alias is passed
* add accept parameter to SimpleQueue class (#1140)Luis Saavedra2021-05-222-7/+37
| | | | | | | | | | | | | * add accept parameter to SimpleQueue class * Fixed missing accept for get_nowait() and added unittests * Remove unused **kwargs from SimpleQueue.__init__ * Use self.consumer.accept instead of new attribute in SimpleQueue * Add tests for simple interface when accept=[] Co-authored-by: Matus Valo <matusvalo@gmail.com>
* Revert "chore: Refactor code quality issues (#1320)" (#1342)Matus Valo2021-05-195-3/+8
| | | This reverts commit 3b6cd13d3b6da22f86a23b93b66c49133776cc75.
* chore: Refactor code quality issues (#1320)Aksh Gupta2021-04-285-8/+3
| | | | | * chore: refactor code quality issues * remove .deepsource.toml config file
* Ignore kombu.transport.librabbitmq in apicheck.Matus Valo2021-04-141-0/+1
| | | | | We are ignoring kombu.transport.librabbitmq because apicheck is failing due missing librabbitmq library.
* Remove unused appveyor and travis configuration filesMatus Valo2021-04-142-133/+0
|
* Make flake8 and pydocstyle happy (#1333)Matus Valo2021-04-139-123/+237
| | | | | * Make flake8 happy * Make pydocstyle happy
* Coerce seconds argument to a floating point number.Omer Katz2021-04-131-1/+1
| | | | | Celery does not coerce configuration values into the right type (See celery/celery#6696). This is a workaround. This bug will be fixed in Celery NextGen when we will refactor our configuration subsystem.
* re order CI jobs to make lint the lastAsif Saif Uddin2021-04-131-23/+24
| | | it was decided long ago and it let the unit and integrations tests run fast for faster feedback loop
* Opencollective bot is now configured.Omer Katz2021-04-131-0/+18
|
* Add support for SQLAlchemy 1.4. (#1328)Omer Katz2021-04-061-1/+6
|
* Fix CI failure (#1327)Omer Katz2021-04-061-6/+6
| | | | | | | * Update before installing system dependencies. * Actually run the linters using tox. There are no environments named py-flake8, py-pydocstyle and py-apicheck.
* Azure Service Bus - versatile queue names fix (#1324)Tomasz Niedziela-Brach2021-04-042-1/+28
| | | | | | | | | * fixed character replace table according to the comment above - dots replaced by dashes, other punctuations replaced by underscores * optimised with precalculated punctuation set - according to @thedrow suggestion * queue name tests * cleanup
* Bump version: 5.0.2 → 5.1.0b1v5.1.0b1Asif Saif Uddin (Auvi)2021-04-014-4/+4
|
* added changlog for v5.1.0b1Asif Saif Uddin (Auvi)2021-04-011-0/+37
|
* Use a thread-safe implementation of cached_property (#1316)Omer Katz2021-04-013-50/+41
| | | | | | | | | | | | | * Use a thread-safe implementation of cached_property. * Restore setter and deleter. * Restore tests. * Fix __get__ signature for backport. * Cleanup. Co-authored-by: Asif Saif Uddin <auvipy@gmail.com>
* min py-amqp to v5.0.6 (#1325)Asif Saif Uddin2021-04-011-1/+1
|
* SQS Broker - handle STS authentication with AWS (#1322)gal cohen2021-03-292-15/+134
| | | | | | | | | | | | | | | | | | | | | * handle sqs sts * add doc * use string format * improve docs * Update kombu/transport/SQS.py Co-authored-by: Omer Katz <omer.drow@gmail.com> * add helper method and tests * changer to private Co-authored-by: galcohen <gal.cohen@autodesk.com> Co-authored-by: Asif Saif Uddin <auvipy@gmail.com> Co-authored-by: Omer Katz <omer.drow@gmail.com>
* Update default login method for librabbitmq and pyamqp (#936)Davis Kirkendall2021-03-242-2/+2
| | | - AMQPLAIN is only retained for backwards compatability and has become non-standard
* Small doc fixes (#1319)Gabriel Niebler2021-03-181-11/+19
| | | | | | | | | | | | | | | * Clean up grammar in paragraph about callbacks * Structure event draining examples into subsections * Make code example make more sense … and bring it more in line with text above. * Fix code example * Fix another code example typo in method name
* Drop obsolete code importing pickle (#1315)Illia Volochii2021-03-161-7/+1
| | | | | https://docs.python.org/3.9/whatsnew/3.0.html#library-changes > A common pattern in Python 2.x is to have one version of a module implemented in pure Python, with an optional accelerated version implemented as a C extension; for example, pickle and cPickle. This places the burden of importing the accelerated version and falling back on the pure Python version on each user of these modules. In Python 3.0, the accelerated versions are considered implementation details of the pure Python versions. Users should always import the standard version, which attempts to import the accelerated version and falls back to the pure Python version. The pickle / cPickle pair received this treatment.
* Fix tiny mistake in introduction (#1312)Gabriel Niebler2021-03-161-3/+3
| | | | | | | | | * Fix tiny mistake in introduction … at least I _think_ it's a mistake. * Remove unused import in code example * Fix minor grammatical errors
* Drop support for the lzma backport.Omer Katz2021-03-162-28/+20
|
* Update connection.py (#1311)Krogsager2021-03-151-1/+6
| | | | | Based on my headaches with silent revert to `localhost` I submit this PR. The developer should be notified if their host settings are not found. Details on the issue are here: https://github.com/celery/celery/issues/6661
* Update default pickle protocol version to 4 (#1314)Illia Volochii2021-03-151-3/+2
| | | | | Protocol version 4 was added in Python 3.4 and is supported by all Python versions that kombu supports. https://docs.python.org/3.9/library/pickle.html#data-stream-format
View Lorry Controller Status