kombu
kombu copied to clipboard
Messaging library for Python.
Good evening folks, Given a list of urls or a string containing multiple urls to the Kombu Connection object, I see that kombu currently supports switching between broker urls for...
I'm currently in process of upgrading these three packages: kombu 5.1.0 -> 5.3.5 celery 5.1.2 -> 5.3.6 azure-servicebus 7.8.1 -> 7.11.4 But found that Celery was throwing a TypeError when...
This PR updates [pytest](https://pypi.org/project/pytest) from **8.2.0** to **8.2.1**. Changelog ### 8.2.1 ``` ========================= Improvements ------------ - `12334 <https://github.com/pytest-dev/pytest/issues/12334>`_: Support for Python 3.13 (beta1 at the time of writing). Bug Fixes...
broker heartbeats clutter the logs console which prevents users from seeing important logs. this allows users to disable broker heartbeats if timeout isn't provided. [reference issue](https://github.com/celery/kombu/issues/1997)
# Checklist - [x] I have checked the [issues list](https://github.com/celery/celery/issues?q=is%3Aissue+label%3A%22Issue+Type%3A+Enhancement%22+-label%3A%22Category%3A+Documentation%22) for similar or identical enhancement to an existing feature. - [x] I have checked the [pull requests list](https://github.com/celery/celery/pulls?q=is%3Apr+label%3A%22Issue+Type%3A+Enhancement%22+-label%3A%22Category%3A+Documentation%22) for existing...
**async function** ``` @celery_app.task() @PowerApp.get('/') async def LetView(): async with db_session() as session: try: print(e) except Exception as e: print(e) ``` **Asynchronous function calls, use **_LetView.delay()_**** ``` @app.get("/test") @celery_app.task(acks_late=True) def...
The azure-servicebus transport depends on azure-identity package, even though it is not listed: https://github.com/celery/kombu/blob/d620132ecee40fc021f7a78750dfe01331e8a8c0/requirements/extras/azureservicebus.txt#L1 It looks like the code intends for it to be optional: https://github.com/celery/kombu/blob/d620132ecee40fc021f7a78750dfe01331e8a8c0/kombu/transport/azureservicebus.py#L72-L77 But of course it...
Fix for issue #2031 1. merge the common code to refresh the sts token in one if-block, i.e. either when sts token not present or when the token is going...
Bumps [pymongo](https://github.com/mongodb/mongo-python-driver) from 4.7.3 to 4.8.0. Release notes Sourced from pymongo's releases. PyMongo 4.8.0 Changes in Version 4.8.0 PyMongo 4.8 brings a number of improvements including: The handshake metadata for...
Hello team ! We use kombu in one of our project and discovered that it use pyrabbit as dependency, a package not upgraded since 9 year. Is it planned to...