maestro-server/analytics-maestro

from app.libs.jwt import Jwt
from app import celery
from app.libs.logger import logger
from app.repository.externalMaestroAnalyticsFront import ExternalMaestroAnalyticsFront
from .notification import task_notification
from app.tasks.ws import task_ws

@celery.task(name="send.server")
def task_send_to_front_app(owner_id, graph_id, payload):

    try:
        token = Jwt.create_tkn(graph_id, owner_id)
        access = Jwt.encode(token)
    except Exception as error:
        logger.error(error)
        task_notification.delay(graph_id=graph_id, msg=str(error), status="danger")

    headers = {
        'Authorization': 'JWT %s' % access.decode("utf-8")
    }

    ExternalMaestroAnalyticsFront(graph_id) \
        .set_headers(headers) \
        .post_request(path="graphs", body=payload)

    task_ws.delay(graph_id, owner_id)
    return {'graph_id': graph_id, 'owner_id': owner_id}