Не удается запустить celery из кода, бесконечное ожидание
Я попытался настроить все по докам, но результата нет.
Желательно запускать celery из кода что бы банально не забыть
tasks.py
from redis import Redis as redis_Redis
from celery import Celery
redis_drivers_queue = redis_Redis(db=0, port=6379, host='localhost')
redis_drivers_result = redis_Redis(db=1, port=6379, host='localhost')
app = Celery(main=__name__, broker='redis://localhost:6379/0', backend='redis://localhost:6379/1')
app.conf.humanize(with_defaults=False, censored=False)
app.conf.update(result_expires=3600)
@app.task
def foo():
print(222)
return 444
if __name__ == '__main__':
app.worker_main([__name__, '--loglevel=DEBUG'])
main.py
import tasks
r = tasks.foo.delay()
r.status
'PENDING' # Всегда
r.backend
<celery.backends.redis.RedisBackend object at 0x7f698fa3f910>
В самом редисе так-же пусто
david@david-ThinkPad-E480:~$ redis-cli -n 1
127.0.0.1:6379[1]> KEYS *
(empty list or set)
127.0.0.1:6379[1]>