| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
|
|
|
| |
* chore(py2): get rid of Python 2 specific requirements
* chore(ci-windows): unify linux and windows requirements
---------
Co-authored-by: Stevie Gayet <stegayet@users.noreply.github.com>
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
|
|
|
| |
* chore(python): remove Python 3.7 support
* Update setup.py
---------
Co-authored-by: Stevie Gayet <stegayet@users.noreply.github.com>
Co-authored-by: Asif Saif Uddin <auvipy@gmail.com>
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* chore(ci): align python version between matrix and tox config
* chore(pydocstyle): upgrade pydocstyle to 6.3.0
* chore(pydocstyle): exclude rules
* fix(mypy): fix `[truthy-function]` error
* fix(pydocstyle): fix D205 rule
* fix(pydocstyle): fix D212 rule
* fix(pydocstyle): fix D407 rule
* fix(pydocstyle): fix D412 rule
* fix(pydocstyle): fix D406 rule
* fix(pydocstyle): fix D411 rule
---------
Co-authored-by: Stevie Gayet <stegayet@users.noreply.github.com>
|
|
|
|
|
|
|
|
|
| |
* chore(build): remove deprecated `zip_safe` parameter
* chore(build): remove `cmdclass` parameter
---------
Co-authored-by: Stevie Gayet <stegayet@users.noreply.github.com>
|
|
|
|
|
|
|
|
|
| |
* chore(ci): use pypy3.9 to get rid of useless step
* chore(ci): pin setup-python to v4
---------
Co-authored-by: Stevie Gayet <stegayet@users.noreply.github.com>
|
| |
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
| |
* Update redis.txt to 4.3.6 to fix severe issue
* Update requirements/extras/redis.txt
* Update requirements/extras/redis.txt
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Fix #1618: avoid re-fetching queue URL when we already have it
`_get_from_sqs` was unnecessarily calling `get_queue_url` every
time even though the only place which calls `_get_from_sqs`
(that is `_get_async`) actually already knows the queue URL.
This change avoids hundreds of `GetQueueUrl` AWS API calls per hour
when using this SQS backend with celery.
Also `connection` is set by the one-and-only caller (and `queue` is
actually the queue name string now anyway so couldn't ever have
`.connection`) so remove the None default and unused fallback code.
* Clarify that `_new_queue` returns the queue URL
It seems that prior to 129a9e4ed05b it returned a queue
object but this is no longer the case so update comments
variable names accordingly to make it clearer.
Also remove the incorrect fallback which cannot
be correct any more given the return value has to
be the queue URL which must be a string.
* Unit test coverage for SQS async codepath
This key code path (which as far as I can see is
the main route when using celery with SQS) was
missing test coverage.
This test adds coverage for:
`_get_bulk_async` -> `_get_async` -> `_get_from_sqs`
|
|
|
|
|
| |
* fix mongodb transport obsolete calls + add test mock specs to check valid methods
* fix linting
|
|
|
|
|
| |
updates:
- [github.com/PyCQA/autoflake: v2.0.2 → v2.1.0](https://github.com/PyCQA/autoflake/compare/v2.0.2...v2.1.0)
|
| |
|
|
|
| |
Co-authored-by: semgrep.dev on behalf of @Nusnus <support@r2c.dev>
|
| |
|
|
|
| |
cpython only again
|
|
|
|
|
|
|
|
|
| |
in qos and perform basic_ack (#1691)
* fix: handle keyerror when message is not found in qos and perform basic_ack
* fix: added tests for basic_ack
* fix: limit line length
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Main
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Fix
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Fix
* Trigger Build
* Fix
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Fix
* Fix
* noqas
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Fix
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* remove unused noqa
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* re-add import
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Fix
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Fixes
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* use pytest-freezer (#1683)
* Main
* Trigger Build
* Fixes
* remove
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* lint
* Lint
---------
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>
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
|
| |
* Update azureservicebus.txt cpython only
* Update azureservicebus.txt
|
| |
|
| |
|
| |
|
|
|
|
|
| |
updates:
- [github.com/PyCQA/autoflake: v2.0.1 → v2.0.2](https://github.com/PyCQA/autoflake/compare/v2.0.1...v2.0.2)
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* 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
|
|
|
|
| |
3.10. Ref #1663.
|
|
|
| |
Refs #1590
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* 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
|
|
|
|
|
| |
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.
|
| |
|
|
|
|
|
|
| |
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)
|
|
|
|
|
|
|
| |
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.46
* Update requirements/extras/sqlalchemy.txt
* bump
|
|
|
|
|
|
|
|
|
|
|
| |
* support sqla v2.0
* Update kombu/transport/sqlalchemy/models.py
* update (#1652)
---------
Co-authored-by: Asif Saif Uddin <auvipy@gmail.com>
|