summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* azure-storage-queue>=12.6.0azureQAsif Saif Uddin2023-03-191-1/+1
|
* Update sqlalchemy.txtAsif Saif Uddin2023-03-191-1/+1
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2023-03-141-1/+1
| | | | | updates: - [github.com/PyCQA/autoflake: v2.0.1 → v2.0.2](https://github.com/PyCQA/autoflake/compare/v2.0.1...v2.0.2)
* Update codeql part to v2 (#1665)Asif Saif Uddin2023-03-131-1/+1
|
* updated python versiions in CI (#1663)Asif Saif Uddin2023-03-132-24/+24
| | | | | | | | | | | | | | | * updated python versiions in CI * updated python versiions in CI with * updated tox * updated ci * Update .github/workflows/ci.yaml * Update .github/workflows/ci.yaml * Update .github/workflows/ci.yaml
* Adapt the mock to correctly mock the behaviors as implemented on Python ↵Jason R. Coombs2023-03-121-2/+6
| | | | 3.10. Ref #1663.
* docs: Add notes for kombu.utils.json.register_type (#1660)Serhii Tereshchenko2023-03-021-0/+17
| | | Refs #1590
* refactor: Refactor utils/json (#1659)Serhii Tereshchenko2023-03-022-94/+107
| | | | | | | | | | | | | | | * refactor: Refactor utils/json * Update kombu/utils/json.py * Update kombu/utils/json.py * chore: Use older syntax (no walrus) * chore: Update doscstrings * chore: Fix pydocstyle complaints * chore: Restore previous docstring
* Remove unused `_setupfuns` from serialization.pySerhii Tereshchenko2023-03-011-12/+0
| | | | | Looks like `_setupfuns` is unused and should be removed. If they're used somehow, please explain how, so i can add comment here to avoid future confusion.
* lets check it's compatAsif Saif Uddin2023-02-191-1/+1
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2023-02-071-2/+2
| | | | | | updates: - [github.com/PyCQA/autoflake: v2.0.0 → v2.0.1](https://github.com/PyCQA/autoflake/compare/v2.0.0...v2.0.1) - [github.com/pycqa/isort: 5.11.4 → 5.12.0](https://github.com/pycqa/isort/compare/5.11.4...5.12.0)
* Mark methods accepting Connection instances as suchAurelien Gateau2023-02-021-3/+4
| | | | | | | In MaybeChannelBound, the `__call__()`, `bind()` and `maybe_bind()` methods takes a channel argument. The type annotation say this argument must be a Channel, but it goes through `maybe_channel()`, so it can also be a Connection. Update the annotation to accept both Channel and Connection.
* sqlalchemy>=1.4.1,<2.1 (#1642)Asif Saif Uddin2023-02-011-1/+1
| | | | | | | * sqlalchemy==1.4.46 * Update requirements/extras/sqlalchemy.txt * bump
* support sqla v2.0 (#1651)Craig Mulligan2023-02-012-4/+4
| | | | | | | | | | | * support sqla v2.0 * Update kombu/transport/sqlalchemy/models.py * update (#1652) --------- Co-authored-by: Asif Saif Uddin <auvipy@gmail.com>
* update (#1652)Asif Saif Uddin2023-02-011-2/+2
|
* azure service bus: add type annotations and use cached propertyJason Barnett2023-01-052-32/+46
|
* add type annotations to kombu/transport/azurestoragequeuesJason Barnett2023-01-031-15/+17
|
* add --keep-runtime-typing argument to pyupgrade (#1639)Jason Barnett2023-01-021-1/+1
| | | Per https://github.com/celery/kombu/pull/1632 @thedrow asked to add this argument so `Optional` is still used.
* [pre-commit.ci] pre-commit autoupdate (#1635)pre-commit-ci[bot]2023-01-021-1/+1
| | | | | | updates: - [github.com/pycqa/isort: v5.11.3 → 5.11.4](https://github.com/pycqa/isort/compare/v5.11.3...5.11.4) Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
* Switch references to master to mainOmer Katz2022-12-294-11/+11
|
* add autoflake to .pre-commit-config.yaml to automatically remove unused ↵Jason Barnett2022-12-282-1/+7
| | | | | | | | | | | imports (#1637) * add autoflake to .pre-commit-config.yaml to automatically remove unused imports * [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>
* add managed identity support to azure storage queue (#1631)Jason Barnett2022-12-274-11/+86
| | | | | * add managed identity support to azure storage queue * flake8 fixes
* redis==4.3.4 temporarilly in an attempt to avoid bc (#1634)Asif Saif Uddin2022-12-271-1/+1
| | | | | * redis==4.3.4 temporarilly in an attempt to avoid bc * redis>=4.2.2,<4.4.0
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2022-12-201-1/+1
| | | | | updates: - [github.com/pycqa/isort: 5.10.1 → v5.11.3](https://github.com/pycqa/isort/compare/5.10.1...v5.11.3)
* Allowing `Connection.ensure()` to retry on specific exceptions given by ↵Tomer Nosrati2022-12-182-1/+55
| | | | | | | | | policy (#1629) * Added unit test: test_ensure_retry_errors_is_not_looping_infinitely() * Added unit test: test_ensure_retry_errors_is_limited_by_max_retries() * Added retry_errors arg to Connection.ensure() to allow applying retry policy for specific errors additionally
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2022-12-141-3/+3
| | | | | | | updates: - [github.com/asottile/pyupgrade: v3.2.0 → v3.3.1](https://github.com/asottile/pyupgrade/compare/v3.2.0...v3.3.1) - [github.com/PyCQA/flake8: 5.0.4 → 6.0.0](https://github.com/PyCQA/flake8/compare/5.0.4...6.0.0) - [github.com/pre-commit/pre-commit-hooks: v4.3.0 → v4.4.0](https://github.com/pre-commit/pre-commit-hooks/compare/v4.3.0...v4.4.0)
* sqlalchemy==1.4.45 (#1626)Asif Saif Uddin2022-12-141-1/+1
| | | | | | | * pin sqlalchemy==1.4.44 * sqlalchemy==2.0.0b4 * sqlalchemy==1.4.45
* Added .python-version and .vscode to gitignoreTomer Nosrati2022-12-141-0/+2
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2022-11-051-1/+1
| | | | | updates: - [github.com/asottile/pyupgrade: v3.1.0 → v3.2.0](https://github.com/asottile/pyupgrade/compare/v3.1.0...v3.2.0)
* Use SPDX license expression in project metadataFrazer McLean2022-10-291-1/+1
|
* Bump version: 5.3.0b1 → 5.3.0b2v5.3.0b2Asif Saif Uddin2022-10-194-4/+4
|
* added changelog entry for v5.3.0b2Asif Saif Uddin2022-10-191-0/+15
|
* [pre-commit.ci] pre-commit autoupdatepre-commit-ci[bot]2022-10-191-1/+1
| | | | | updates: - [github.com/asottile/pyupgrade: v3.0.0 → v3.1.0](https://github.com/asottile/pyupgrade/compare/v3.0.0...v3.1.0)
* Allow azurestoragequeues transport to be used with Azurite emulator in ↵David Bossanyi2022-10-162-1/+29
| | | | | | | | | | | | | | | docker-compose (#1611) * Parse credential as a dict when using Azurite emulator This more flexible credential allows the use of Azurite for integration testing in local docker-compose configurations. * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci * Fix some lint errors 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]2022-10-131-3/+3
| | | | | | | updates: - [github.com/asottile/pyupgrade: v2.37.1 → v3.0.0](https://github.com/asottile/pyupgrade/compare/v2.37.1...v3.0.0) - [github.com/PyCQA/flake8: 4.0.1 → 5.0.4](https://github.com/PyCQA/flake8/compare/4.0.1...5.0.4) - [github.com/asottile/yesqa: v1.3.0 → v1.4.0](https://github.com/asottile/yesqa/compare/v1.3.0...v1.4.0)
* Fix errors from flake8 lintMarti Raudsepp2022-10-125-9/+9
| | | | | Python's `del` is a statement, not a function, and doesn't need parenthesis.
* Add separate transport option for retry loop timeout (#1599)Marti Raudsepp2022-10-123-2/+49
| | | | | | | | | | | | | | | | | | | | | * Add separate transport option for retry loop timeout This only applies when using `Connect.default_channel`. Before this change, the retry loop timeout was set equal to TCP connect timeout (`connect_timeout`), meaning when first connection attempt timeouted, no retry would be attempted. Now if a new transport option `connect_total_timeout` is provided, this overrides `connect_timeout` for the retry loop (but not for TCP connect). * Add tests * Fix isort * Rename to connect_retry_timeout * Reformat * connect_retry_timeout -> connect_retries_timeout * Fix flake8
* importlib_metadata remove deprecated entry point interfaces (#1601)woutdenolf2022-10-092-2/+7
| | | | | * importlib_metadata removed deprecated entry point interfaces * importlib-metadata usage requires 3.6
* Solve Kombu filesystem transport not thread safekarajan10012022-09-232-30/+102
| | | | | | partly fix: #398 1. add exclusive lock during the whole exchange file update. 2. add some unit test for file lock
* Make JSONEncoder keep the same type for date/datetime.Manuel Vázquez Acosta2022-09-213-3/+9
| | | | | | | Otherwise Celery jobs start to get `datetime` in place of `date` and that could lead to errors. See https://github.com/celery/celery/issues/7754, related PR #1515.
* Revert "Solve Kombu filesystem transport not thread safe (#1593)" (#1595)Gao2022-09-092-170/+29
| | | This reverts commit 8699920e050727d385a6d5a19c939e55a86688d6.
* Solve Kombu filesystem transport not thread safe (#1593)Gao2022-09-072-29/+170
| | | | | | | | | | | | | | * Solve Kombu filesystem transport not thread safe fix: #398 Currently only write lock used in msg/exchange file written. Cause reading in other thread got some incomplete result. 1. Add timeout for the lock acquire. 2. Add Share locks when reading message from filesystem. 3. Add a unit test for the `lock` and `unlock` 4. Add a unit test to test the lock during message processing. * Replace deprecated function.
* Fix incompatibility with redis in disconnect() (#1589)Shalabh Chaturvedi2022-08-252-2/+18
| | | | | * Accept *args in disconnect() * Add test for redis connection timeout error
* hub: tick delay fix (#1587)Shahar Lev2022-08-242-4/+22
| | | | | | | | | | | | | | | | | | | | | * hub: tick delay fix todo and timer callbacks can perform actions that require a tick callback to be executed right away without polling. the current order can cause issues when using single worker with no prefetch (acks late). related issue in celery: https://github.com/celery/celery/issues/7718 * add unit test for hub delay fix * [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: save QueueProperties to _queue_name_cache instead of QueueClientdavidbossanyi2022-08-211-1/+1
|
* Change print styleJaeyoungHeo2022-08-031-1/+1
|
* Bump version: 5.3.0a1 → 5.3.0b1v5.3.0b1Asif Saif Uddin2022-08-014-4/+4
|
* added changelog entry for v5.3.0b1Asif Saif Uddin2022-08-011-0/+13
|
* chore: add confluentkafka to extras 📌Meysam Azad2022-07-182-1/+2
|
* Avoid losing type of UUID when serializing/deserializing (#1575)Carlos Gottberg2022-07-173-6/+25
| | | | | | | | | | | | | | | | | | | | | * Avoid losing type of UUID when serializing/deserializing Serializing UUIDs as strs and deserializing them as strs can lead to somewhat obscure bugs such as the one that led to the creation of this PR in django-cacheback https://github.com/codeinthehole/django-cacheback/pull/100 which some would call unexpected behaviour. After all, an UUID is altogether a different type from strs and if bytes got their own serializer/deserializer for UUID the same logic should apply. * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci * Update documentation for JSON serialization Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
View Lorry Controller Status