Get return function task #1342

jonatasoli · 2024-04-03T20:02:04Z

jonatasoli
Apr 3, 2024

Hi,

I have asked from a problem with the return function.
I have a function below in my services.py

    cart_uuid: str,
    payment_method: str,
    payment_gateway: str,
    user: Any,
    bootstrap: Any = Depends(get_bootstrap),
    checkout_task = await bootstrap.message.broker.publish(
        {
            'cart_uuid': uuid,
            'payment_gateway': cache_cart.gateway_provider,
            'payment_method': cache_cart.payment_method,
            'user': user,
        },
        queue=RabbitQueue('checkout'),
    )

checkout_task is a variable receive the return this checkout task ex:.
task.py

@worker.subscriber
async def checkout(
cart_uuid: str,
payment_method: str,
payment_gateway: str,
user: Any,
bootstrap: Any = Depends(get_bootstrap),
) -> dict:

return { 'status': ok, 'processing''ok' }


I need get the return in checkout task but this form I don´t receive this return, I go from propan lib in this case I use `callback` flag to inform this task is need wait the return, but I don't see how done this form in faststream.