from celery import Celery
from celery import group, chord, chain
from threading import Thread
from flask import Flask

flask_app = Flask(__name__)
app = Celery(broker='redis://localhost:6379/0', backend='redis')

@app.task(ignore_result=False)
def add(x, y):
    print('x + y')
    return x + y

@app.task(ignore_result=False)
def _on_success(*args, **kwargs):
    print('oi deu bom')

@flask_app.route("/vai")
def call_task():
    print('call_task')
    # _on_success.s()
    chord([add.s(1,2), add.s(1,2), add.s(1,2), add.s(1,2)])(_on_success.s())
    # answer = result.get()
    # print('result aqui >>> %s' %)
    return 'enviou essa porra', 200

if __name__ == "__main__":
    print("oi")
    flask_thread = Thread(target=flask_app.run, kwargs={'port': 5005})
    flask_thread.start()

    celery_worker = Thread(target=app.worker_main)
    celery_worker.start()