How to configure kombu to use existing redis lists

[vshulgin]

Hello team,

We've got a running redis with some legacy code publishing to redis lists.
I'm trying to configure celery with kombu to consume from this lists.
Is it possible? When I try to configure it, it creates several sets in redis, but is it is not expected.

The configuration is pretty straighforward:

from common.inits import settings
from celery import Celery
from kombu import Queue, Exchange

celery = Celery('celerys', include=['celerys.tasks'])
celery.conf.broker_url = f"redis://:{settings['redis'].password}@{settings['redis'].host}:{settings['redis'].port}/{settings['redis'].db}"

celery.conf.task_default_queue = 'default'
celery.conf.task_queues = [
    Queue(
        name='firestarter',
        exchange=Exchange('default', type='direct'),
        routing_key='task.firestarter',
        delivery_mode=1,
        durable=False,
        auto_delete=True
    )
]

And result in redis as follow:

127.0.0.1:6379> keys *
1) "_kombu.binding.celery.pidbox"
2) "_kombu.binding.default"
3) "firestarter"
4) "_kombu.binding.celeryev"

Where the firestarter is legacy list, and the rest are set. Why sets?
And how to get it consume from firestarter?

Thanks

[open-collective-bot[bot]]

Hey @TalyGin 👋,
Thank you for opening an issue. We will get back to you as soon as we can.
Also, check out our Open Collective and consider backing us - every little helps!

We also offer priority support for our sponsors.
If you require immediate assistance please consider sponsoring us.