Adicionar celery ao projeto

[Mdslino]

Teria uma forma de adicionar o celery ao projeto e carregar dinamicamente assim como as outras extensões?

[rochacbruno]

Tem sim e seria uma boa idéia adicionar o Celery e o flask-rq

[Mdslino]

Eu consegui através do flask-celery-helper, vou fazer mais alguns testes se estiver legal abro uma PR

[ThallyssonKlein]

@Mdslino conseguiu fazer funcionar?

[revton]

Olhando para Flask-Celery-Helper, está descontinuada.
Utilizei um fork dele chamado Flask-Celery-Tools v1.4.1, com Flower v0.9.7 e Celery v4.4.7.
Para coisas simples funcionou bem.
A única coisa que não consegui no momento, foi carregar as variáveis de ambientes no Worker, usando o Dynaconf. Apliquei dentro da task que precisava load_dotenv.
Vou fazer mais alguns testes, caso não consiga, devo abrir uma issue no repositório do Dynaconf.

Atualizando solução

Encontrei essa resposta no StackOverflow que remove a necessidade do Flask-Celery-Helper, implementei desta forma.

celery_extension.py

from celery import Celery
celery = Celery()

queue.py

from celery_extension import celery

def init_app(app: Flask):
    celery.config_from_object(app.config, namespace='CELERY')

Chama o init_app do queue.py usando o Dynaconf dentro do create_app.

run_celery.py

from app import create_app
from celery_extension import celery

app = create_app()

if __name__ == '__main__':
    with app.app_context():
        celery.start()

settings.toml

CELERY_BROKER_URL = "amqp://admin:admin@localhost:5672//"
CELERY_RESULT_BACKEND = "rpc://"

Para subir a o celery

python run_celery.py worker --loglevel=info