kombu

kombu copied to clipboard

Support Switching broker Url for Operational(Publish only) failures

1

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

dheerajtenepalli

TypeError: `isinstance` when azure-identity is not imported using Azure Service Bus transport

1

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

jesusgarmanz

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

pyup-bot

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)

smart-programmer

# 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...

smart-programmer

Coroutine can't seem to be called directly by Celery

7

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

EITSxiaozhai

Azure servicebus transport has hidden dependency on azure-identity package

1

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

Korijn

fix to refresh sts token at 80% of TTL for issue #2031

3

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

chenxg283

Bump pymongo from 4.7.3 to 4.8.0

1

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

dependabot[bot]

Remove pyrabbit

2

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

murlock