kombu

kombu copied to clipboard

Redis transport causes multiple Celery job runs if eta exceeds visibility timeout

29

Caveat - I initially tracked down and patched this problem over a year ago, but never opened an Issue on it. Looking at the Kombu 3 code it appears to...

bigo

Redis message TTL support

4

Current versions of Redis support automatic expires of keys. Can [message_ttl](https://docs.celeryproject.org/projects/kombu/en/stable/reference/kombu.html#kombu.Queue.message_ttl) support be extended to REDIS instances as well?

jcpunk

Use another augmented assignment statement

3

:eyes: Some source code analysis tools can help to find opportunities for improving software components. :thought_balloon: I propose to [increase the usage of augmented assignment statements](https://docs.python.org/3/reference/simple_stmts.html#augmented-assignment-statements "Augmented assignment statements") accordingly....

elfring

I will clean up the codes after rebase and split some clean codes as mergeable small PR.

auvipy

Add support for custom yaml encoding

6

if `__yaml__` method is implemented, then use it to instruct the yaml Encoder on how to perform arbitrary custom instances. Related to https://github.com/celery/celery/issues/6901

ticosax

add gossip not supported exception

galCohen88

Port of redis code improvements from prior revision

3

This is continuation of #1132. The pending point of this PR are failing integration tests.

matusvalo

Kombu does correct support multi-threading sqla broker

2

In case running Celery with `sqla+postgresql+psycopg2` broker with prefork model I facing with problem - all broker connection is died. In logs we found error - `This session in "prepared"...

CrazyLionHeart

SimpleQueue.get()'s body attribute is a string when using py-amqp, but a buffer with librabbitmq

6

It's my understanding that librabbitmq is meant to be a drop-in replacement for py-amqp, that kombu will use if present and will otherwise fall back to the latter. Using Python...

edmorley

Hi, If login_method is specified, the qpid authentication fails. This is, because of code in kombu/transport/qpid.py, where the only handled situation is when "login_method" is not specified. If it is...

balonik