delta/python-packages/kombu.git/t, branch py310 github.com: celery/kombu.git Adapt the mock to correctly mock the behaviors as implemented on Python 3.10. Ref #1663. 2023-03-12T16:33:37+00:00 Jason R. Coombs jaraco@jaraco.com 2023-03-12T14:59:27+00:00 c310364cc039e1e78419b74b490ad2ddb5e017d4 






refactor: Refactor utils/json (#1659)
2023-03-02T10:18:21+00:00

Serhii Tereshchenko
serg.partizan@gmail.com

2023-03-02T10:18:21+00:00

6fe50f5985b01c1f9b172f740c51400540bfc92d

* 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




* 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






azure service bus: add type annotations and use cached property
2023-01-04T18:34:46+00:00

Jason Barnett
jason.w.barnett@gmail.com

2023-01-02T19:09:15+00:00

d3ca0d562e7c3ee9f8b0cfffb3bb798b98c28a84












add managed identity support to azure storage queue (#1631)
2022-12-26T18:51:47+00:00

Jason Barnett
J@sonBarnett.com

2022-12-26T18:51:47+00:00

4fac6bc84c1374e5cde8cfd2125f214d1830b5f4

* add managed identity support to azure storage queue

* flake8 fixes




* add managed identity support to azure storage queue

* flake8 fixes






Allowing `Connection.ensure()` to retry on specific exceptions given by policy (#1629)
2022-12-18T10:34:57+00:00

Tomer Nosrati
tomer.nosrati@kcg.tech

2022-12-18T10:34:57+00:00

44025bfa528f4b255e371d130f7fa39b05e16840

* 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




* 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






Allow azurestoragequeues transport to be used with Azurite emulator in docker-compose (#1611)
2022-10-16T14:43:15+00:00

David Bossanyi
davebossanyi@gmail.com

2022-10-16T14:43:15+00:00

22b559684f62417d47a0370e5f8f65b9278a9903

* 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>




* 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>






Fix errors from flake8 lint
2022-10-12T14:47:19+00:00

Marti Raudsepp
marti@juffo.org

2022-10-12T11:25:10+00:00

bfec7faf8d2c7956b35a56b5c93152e4511554d7

Python's `del` is a statement, not a function, and doesn't need
parenthesis.





Python's `del` is a statement, not a function, and doesn't need
parenthesis.







Add separate transport option for retry loop timeout (#1599)
2022-10-12T13:41:04+00:00

Marti Raudsepp
marti@juffo.org

2022-10-12T13:41:04+00:00

3a49533bc283eb03dae772ca79a6aa4f1c68f083

* 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




* 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






Solve Kombu filesystem transport not thread safe
2022-09-23T11:29:34+00:00

karajan1001
mishanyo1001@gmail.com

2022-09-12T11:08:44+00:00

6ae9fac150305bb6ee83192a4cccf54613efcb2f

partly fix: #398
1. add exclusive lock during the whole exchange file update.
2. add some unit test for file lock





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.
2022-09-21T06:24:08+00:00

Manuel Vázquez Acosta
manuel@merchise.org

2022-09-20T14:54:35+00:00

2d88c43feff2cab9011568eb1abe44e13b7c7207

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.





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.