kombu

kombu copied to clipboard

updates: - [github.com/asottile/pyupgrade: v2.37.1 → v2.38.0](https://github.com/asottile/pyupgrade/compare/v2.37.1...v2.38.0) - [github.com/PyCQA/flake8: 4.0.1 → 5.0.4](https://github.com/PyCQA/flake8/compare/4.0.1...5.0.4) - [github.com/asottile/yesqa: v1.3.0 → v1.4.0](https://github.com/asottile/yesqa/compare/v1.3.0...v1.4.0)

pre-commit-ci[bot]

kombu.exceptions.EncodeError: cannot pickle 'TaskStepMethWrapper' object

1

I get an error when I pass a class as a parameter.How to implement the class passed to the task for processing

zhenzi0322

Task.delay() hang forever when rabbitmq is down

10

# Checklist * [x] I have verified that the issue exists against the `master` branch of Celery. * [x] This has already been asked to the [discussion group](https://groups.google.com/forum/#!forum/celery-users) first. *...

thanhpd-teko

In mutlithreading flow the add_consumer method gets stuck in infinite loop

7

When I tried to call the add_consumer(https://github.com/celery/celery/blob/515f98b7072677439423a15035541d24bfcb2348/celery/app/control.py#L554) method for the non-existing(which might also possible that worker is in `not responding` state) worker then the process went into an infinite loop...

rakeshbabuseva

Based on my local & confluent tests, the same transport class can be used for both `confluentkafka` and `kafka` itself. I've done countless tests and it works. Based on the...

meysam81

Request: Accept full range of azure storage queue connection parameters

6

I'd like to test the azure storage queue transport locally using the Azure Storage emulator, Azurite [[link](https://github.com/Azure/Azurite)], which allows you to host a version of the blob and queue storage...

cbcoutinho

Add support to submodules

1

yqkcn

Support for SQS DelaySeconds

4

SQS has a built-in "DelaySeconds" feature that could support Celery's ETA/Countdown feature for up to 15 minutes. https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-send-message-with-timer.html

ikonst

Plan to annotate - Kombu

10

# Fully Type Annotation - Kombu Analogous to https://github.com/celery/celery/issues/7394. | Status | Filename | PR | | :----: | ---------------------------------------- | --- | | ✅ | **\_\_init\_\_.py** | #1527 |...

Kludex

JSON decode error "Expecting value: line 1 column 1 (char 0)"

8

I'm using the `ConsumerMixin` class to interact with `json` formatted messages appearing in the filesystem of the container that is running the script. It works fine until a message that,...

rdauncey53