import sys
from celery import Celery

app = Celery(__name__, broker="amqp://localhost")


@app.task
def print_result(v):
    print(v)


if __name__ == "__main__":
    x, y, *_ = sys.argv[1:]
    app.send_task(
        "receiver.calculate_result",
        args=(float(x), float(y)),
        queue="in"
    )