kombu

kombu copied to clipboard

autoretry fails to honor max_retries if connection cannot be established

1

If max_retries is passed to connection.autoretry() and the connection is not available then autoretry blocks until a connection is made regardless of the max_retries value. See attached. If you set...

kgiusti

[metadata] section of setup.cfg does nothing

5

I've been looking over how the 3.0 release stream of kombu handles its dependencies, and I can't tell what the purpose of [the metadata section of setup.cfg](https://github.com/celery/kombu/blob/21bc77208f115ee38c3e69561ce5b8f72e6aa9c1/setup.cfg#L25) is. It has...

bmbouter

Add test for Retry policy timeout.

1

Related to #1024 I add a new Pytest plugin (`pytest-timeout`) to stop the tests so It doesn't run forever in Travis/Appveyor

danidee10

[WIP] - attempt to async/await conversion of common functions

10

https://github.com/sqlalchemy/sqlalchemy/commit/5fb0138a3220161703e6ab1087319a669d14e7f4

auvipy

Used a context manager for locks and files in filesystem transport.

5

atombrella

Draft: Add annotations for `utils/scheduling.py`

1

Related to https://github.com/celery/kombu/issues/1511

nils-van-zuijlen

Related to https://github.com/celery/kombu/issues/1511

nils-van-zuijlen

support self signed certificates

3

Hi, I'm using pyamqp maybe this is also valid / interesting for other transport layers. Since version 4.6.8 kombu doesn't accept self signed certificates (at least for amqps connections), which...

vogt31337

Stop automatically converting the amqp:// prefix to librabbitmq:// + refactored test

8

Based on issue [#4693](https://github.com/celery/celery/issues/4693#issuecomment-390771991) on celery repo, librabbitmq is no longer the recommended package, but the code in kombu does not follow this recommendation. It's also been discussed in [PR...

Alireza2n

Celery crashes in cases where it tries to call SQS ChangeMessageVisibility after expired ReceiptHandle

4

We have encountered a problem in our system which is probably closely related to #1198 issue. The message that caused celery crash from the logs: ``ClientError('An error occurred (InvalidParameterValue) when...

ajakubo1