github.com/celery/kombu issues | Ecosyste.ms: OpenCollective

DeprecationWarning - SelectableGroups dict interface is deprecated. Use select.

AbdealiLoKo opened this issue over 3 years ago

SQS - Gossip not supported

galCohen88 opened this pull request over 3 years ago

Coerce seconds argument to a floating point number.

thedrow opened this pull request almost 4 years ago

Activate DeepSource for static analysis

akshgpt7 opened this issue almost 4 years ago

Port of redis code improvements from prior revision

matusvalo opened this pull request almost 4 years ago

added initial draft github action workflow

auvipy opened this pull request almost 4 years ago

Set a reasonable default value for max_retries to avoid infinite loops

bblanchon opened this issue almost 4 years ago

should pywin32, pyrabbit be listed in requirements.txt?

suliuzh opened this issue about 4 years ago

pass timeout on in _extract_failover_opts

sschiessl-bcp opened this pull request over 4 years ago

Passing transport_options to conn_opts in _extract_failover_opts

sschiessl-bcp opened this issue over 4 years ago

Order of the release tags is broken

matusvalo opened this issue over 4 years ago

SQS: JSONDecodeError when reading message from Amazon SQS predefined_queues

januszm opened this issue over 4 years ago

SQS transport does not recover from errors

sveniu opened this issue about 5 years ago

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

atombrella opened this pull request about 5 years ago

Kombu - amqp (cloudamqp) - Connection reset by peer

emakarov opened this issue about 5 years ago

Add test for Retry policy timeout.

danidee10 opened this pull request over 5 years ago

Latest working celery/redis cannot inspect: Error: No nodes replied within time constraint.

jslusher opened this issue over 5 years ago

AMQPDeprecationWarning

vadamoto opened this issue almost 6 years ago

Override missing transport options with the retry policy provided by the publisher

thedrow opened this pull request almost 6 years ago

Producer.publish blocks forever on a closed connection when the transport_options of the connection does not specify a retry_policy

danidee10 opened this issue almost 6 years ago

Instrumenting SQS ApproximateReceiveCount

ikonst opened this issue almost 6 years ago

[WIP] added initial redis cluster transport support code

auvipy opened this pull request almost 6 years ago

"Error 32 while writing to socket. Broken pipe" After upgrading to kombu 4.4.0 and redis 3.2.0

alexandre-paroissien opened this issue almost 6 years ago

[second try] Fixed error when `query` dict has keyname equal to `virtual_host` on `kombu.utils.url.parse_url`

larsrinn opened this pull request almost 6 years ago

Add migrations to our SQLAlchemy transport model

thedrow opened this issue almost 6 years ago

Add must_get_event_loop

ikonst opened this pull request almost 6 years ago

Autoretry errback is not triggered

mcdoker18 opened this issue over 6 years ago

autoretry interval may overflow interval_max setting

kgiusti opened this issue over 6 years ago

Introduce global key prefix for redis transport

wetneb opened this pull request over 6 years ago

zlib doesn't support memoryview

Kronuz opened this issue over 6 years ago

When RabbitMQ is down calling a task is stuck forever (retry settings are ignored)

etiktin opened this issue over 6 years ago

AttributeError: 'tuple' object has no attribute 'startswith'

mpenkov opened this issue over 6 years ago

asyncio eventloop support

Roger opened this issue over 6 years ago

Maybe incorrect description about kombu.Queue in the documentation

bombs-kim opened this issue over 6 years ago

Use logger for "Restoring X unacknowledged message(s)"

blueyed opened this issue over 6 years ago

Connection.collect() is not thread safe

mattbennett opened this issue almost 7 years ago

autoretry fails to honor max_retries if connection cannot be established

kgiusti opened this issue almost 7 years ago

Consumer not gracefully recovering from rabbitmq restarts/issues

naemono opened this issue about 7 years ago

AttributeError after broker shutdown

sseg opened this issue about 7 years ago

kombu silently catches OSError in consumer code

max-vogler opened this issue over 7 years ago

Add support for Queue max_length to other transports

chadrik opened this issue over 7 years ago

- Bugfix: when create a Queue object, can't create binding with Exchange object.

cha-messy opened this pull request over 7 years ago

SQS Messages not being ack'd/deleted

alukach opened this issue over 7 years ago

Drop pycurl requirement

ProTip opened this issue over 7 years ago

Has anyone looked into Cloud Pub/Sub?

listingmirror opened this issue almost 8 years ago

timestamp should be moved out of if statement in TokenBucket._get_tokens()

Jackyele opened this issue about 8 years ago

Pytest config conflicting with pytest-django plugin ?

ldng opened this issue about 8 years ago

SimpleQueue does not support revive like Queue

abhi-911 opened this issue about 8 years ago

Mailbox constructor got queue and reply_queue TTL and Expires options

alanjds opened this pull request over 8 years ago

Heartbeats, correct implementation?

agalera opened this issue over 8 years ago

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

edmorley opened this issue about 9 years ago

ETA tasks lost on worker TERM restart

safwanebrahim-uc opened this issue about 9 years ago

[metadata] section of setup.cfg does nothing

bmbouter opened this issue over 9 years ago

Connect to a random host in a multi-broker config

ginoledesma opened this pull request about 10 years ago

Provide rpc server/client/dispatcher

harlowja opened this issue about 10 years ago

Cache declared entities using a unique key instead of hash.

rectalogic opened this pull request over 10 years ago

maybe_declare does not redeclare Queue bindings

rectalogic opened this issue over 10 years ago

Producer.publish ignores exchange parameter (patch included)

ceremcem opened this issue over 10 years ago

Documentation does not describe purpose of obj argument to Connection.ensure

johtso opened this issue over 10 years ago

Add a requeue_log_error method

harlowja opened this pull request over 10 years ago

Fix issue with Celery control signals not being received after the 2nd time.

rogerhu opened this pull request over 10 years ago

AttributeError: 'ChannelPromise' object has no attribute '__value__'

davidfischer-ch opened this issue over 10 years ago

Blocked Consumers -> simple_task_example

vgoklani opened this issue over 10 years ago

Failover with alternates/list of hostnames in Connection objects does not work

ngie-eign opened this issue over 10 years ago

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

bigo opened this issue almost 11 years ago

Use class-defined attributes as default values

malinoff opened this pull request almost 11 years ago

The alternates keyword isn't documented in kombu.connection.Connection

ngie-eign opened this issue almost 11 years ago

Kafka support

rdiomar opened this issue almost 11 years ago

Orphaned reply pidboxes in Redis

rkul opened this issue about 11 years ago

Support message sizes > 256KB by using a third-party backend...

diranged opened this issue about 11 years ago

a callback function when Consumer.callbacks raises an exception

ttddyy opened this pull request over 11 years ago

SQS broker url doesn't include queue_name_prefix

j0hnsmith opened this issue almost 12 years ago

Asynchronous broadcasts

mher opened this pull request over 12 years ago