kombu 5.3.6

Messaging library for Python.

Stars: 2741, Watchers: 2741, Forks: 906, Open Issues: 207

The celery/kombu repo was created 13 years ago and the last code push was Yesterday.
The project is very popular with an impressive 2741 github stars!

How to Install kombu

You can install kombu using pip

pip install kombu

or add it to a project with poetry

poetry add kombu

Package Details

Author

Ask Solem

License

BSD-3-Clause

Homepage

https://kombu.readthedocs.io

PyPi:

https://pypi.org/project/kombu/

GitHub Repo:

https://github.com/celery/kombu

Classifiers

• Communications
• Software Development/Libraries/Python Modules
• System/Distributed Computing
• System/Networking

Related Packages

Errors

A list of common kombu errors.

Code Examples

Here are some kombu code examples and snippets.

GitHub Issues

The kombu package has 207 open issues on GitHub

• SQS Transport basic_ack does not handle common http errors (ie: AccessDeniedException / 400 http errors)
• 'called_once' is not a valid assertion issues in various tests (probably Python 3.12 related)
• SQS doesn't acknowledge task when it is rejected (like Celery docs say should happen).
• AttributeError: 'ChannelPromise' object has no attribute 'value'
• can't subtract offset-naive and offset-aware datetimes
• Order of the release tags is broken
• SQS transport does not recover from errors
• Used a context manager for locks and files in filesystem transport.
• Add test for Retry policy timeout.
• Latest working celery/redis cannot inspect: Error: No nodes replied within time constraint.
• Producer.publish blocks forever on a closed connection when the transport_options of the connection does not specify a retry_policy
• Instrumenting SQS ApproximateReceiveCount
• [second try] Fixed error when query dict has keyname equal to virtual_host on kombu.utils.url.parse_url
• Add must_get_event_loop
• Autoretry errback is not triggered

See more issues on GitHub