lp:kombu
- Get this branch:
- bzr branch lp:kombu
Branch merges
Branch information
Import details
This branch is an import of the HEAD branch of the Git repository at https://github.com/celery/kombu.git.
Last successful import was .
Recent revisions
- 2338. By Gao <email address hidden>
-
Add fanout to filesystem (#1499)
* Create a folder for each queue when using filesystem transport and add fanout support
* clean up unused variables
* Add fanout support to filesystem transport
filesystem transport lacks of fanout support.
1. Add fanout support to filesystem transport.
2. Add a unit test for it.* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https:/
/pre-commit. ci * Remove the refactoring work and make the test passed
1. Remove all of refactoring work
2. make the test pass* Use pathlib for some Path operation
* Some reviewed changes
Co-authored-by: Yuriy Halytskyy <email address hidden>
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit- ci[bot] @users. noreply. github. com> - 2337. By pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
-
[pre-commit.ci] pre-commit autoupdate
updates:
- [github.com/asottile/ pyupgrade: v2.31.0 → v2.31.1](https:/ /github. com/asottile/ pyupgrade/ compare/ v2.31.0. ..v2.31. 1) - 2333. By Shane Hathaway <email address hidden>
-
Add an option to not base64-encode SQS messages.
Also simplify the base64 decoding logic so that we don't have to
run base64 decoding twice for every message. - 2331. By vinay karanam <email address hidden>
-
Added global_keyprefix support for pubsub clients (#1495)
* Added global_keyprefix support for pubsub clients
* Added test cases
- 2330. By Mads Jensen <email address hidden>
-
All supported versions of Python define __package__.
https:/
/www.python. org/dev/ peps/pep- 0366/ lists Python 2.6 and 3.0 as
the minimum requirements for this attribute. sys.__dict__ contains it. - 2329. By Michael Manganiello <email address hidden>
-
Warn about missing hostname only when default one is available (#1488)
* Warn about missing hostname only when default one is available
The `No hostname was supplied` warning is affecting projects that use
AWS SQS (as detailed in #1357), as a hostname is not required when
setting up the broker URL. Instead, the official documentation [0] specifies
that the valid broker URL formats are:* `sqs://`
* `sqs://aws_access_ key_id: aws_secret_ access_ key@` With these formats, the `kombu.
utils.url. parse_url` util doesn't return
a hostname, and workers end up triggering the following warning:> No hostname was supplied. Reverting to default 'None'
As the SQS transport doesn't provide a default value for hostname, this
diff changes the behavior to only warn the user when the hostname hasn't
been supplied but a default one is being set by the default connection
parameters for the defined transport.Fixes #1357.
[0] https:/
/docs.celerypro ject.org/ en/stable/ getting- started/ backends- and-brokers/ sqs.html# configuration * Use caplog default logging level of WARNING
Branch metadata
- Branch format:
- Branch format 7
- Repository format:
- Bazaar repository format 2a (needs bzr 1.16 or later)