kombu
kombu copied to clipboard
celery
Messaging library for Python.
In order to match how there is a ack_log_error and a reject_log_error it seems appropriate to also provide a requeue_log_error method that is provided in the message class.
There are two issues with kombu/common.py that need to be fixed with this PR. First, the code attempts to avoid declaring exchanges more than once. The problem is that Celery...
Added `on_callback_error` on Consumer. The registered function is invoked when one of the consumer callback functions have failed(throw exception). When True is returned from the function, it will continue the...
As of now kombo default JSON encoder supports a type-conversion mechanism https://github.com/celery/kombu/blob/241b5dcff8a7c8ad411e1b325d59e47acfa9e1ed/kombu/utils/json.py#L36-L58 Also [`msgpack.packb`](https://github.com/msgpack/msgpack-python/blob/cfae52437b0d146f74a14d69cb706712c1fa2c95/msgpack/fallback.py#L672-L674) supports a _default_ callback to handle non-native-types. If msgpack serializer behaves just like JSON one than...
I know that there's this example that use Hub, that it's a partial implementation of tulip https://github.com/celery/kombu/blob/master/examples/experimental/async_consume.py but, is there any support to run consumers using the asyncio event loop?
In its response to [ReceiveMessage](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html), SQS can provide an (optional) attribute called `ApproximateReceiveCount`. This attribute allows for rudimentary diagnostics of retries resulting from worker termination (assuming late ACKs). Can it...
In #850 we discovered that no migrations are provided for the `Message` model. Migrations should be added with [alembic](https://bitbucket.org/zzzeek/alembic) for those who wish to use the transport.
https://github.com/celery/kombu/blob/dba85e2d9515b9ce202bd30e8690131aa055e6bf/kombu/connection.py#L334-L350 If any other thread creates a socket while `Connection.collect()` is mid-execution, the new socket will inherit the temporary timeout. Example here: https://gist.github.com/mattbennett/888e42af88c2733918ad1810956abbde
We found that sometimes we cannot exit from a celery worker. I checked the process tree and found the parent was waiting for one thread to return. Then I checked...
