kombu
kombu copied to clipboard
celery
Messaging library for Python.
when a message has an `properties`.`body_encoding` of `utf-8` (e.g. the default on https://github.com/node-celery-ts/node-celery-ts), celery workers crash with an error `AttributeError: 'NoneType' object has no attribute 'decode'`. `utf-8` is functionally equivalent...
Having the following exception from time to time, not easy to reproduce though. CRITICAL/MainProcess] Unrecoverable error: Exception('Request HTTP Error HTTP 403 Forbidden (b\'{"__type":"com.amazon.coral.service#ExpiredTokenException","message":"The security token included in the request is...
Hi, Thank you very much for the fantastic work you do with Celery. I'm using Celery 4.4.7, and I just spent a lot of time understanding why my server froze...
> orjson is a fast, correct JSON library for Python. It [benchmarks](https://github.com/ijl/orjson#performance) as the fastest Python library for JSON and is more correct than the standard json library or other...
Hi, Recently I started getting the error. I'm not familiar with kombu's data structure and I'm not sure how we getting into this situation. Can someone direct me what I...
1) Is anyone working on cloud pub/sub transport? It is awesome that SQS is now a first class citizen for those in the AWS world. Cloud pub/sub would do the...
Due to the new licensing issues with Redis, I'm currently testing out Microsoft Garnet as an open source caching alternative for the Celery result backend (which uses kombu for messaging)...
Fix for: https://github.com/celery/kombu/issues/1835 Partially also: https://github.com/celery/kombu/issues/1819 Possibly related: https://github.com/celery/celery/discussions/8583 **Issue** when not using short polling (`wait_time_seconds > 0`) and `task_acks_late=True` it is possible for message to become stuck with full...
:wave: First I want to notice that the change in https://github.com/celery/kombu/issues/1997 is backwards incompatible, and still was release on a **minor version** with **no breaking change warning or mention on...
