Graceful shutdown FastAPI integration

[dimbler]

Dear Team,
Thank you for great library.
Please clarify, how can support on_shutdown event in FastAPI integration?
This question related to #965

[Lancetnik]

We are working on this feature. For now, you can add some middleware, taking asyncio.Lock while message is processed and wait for release it in your shutdown event.

[dimbler]

Thank you for rapid answer.
Probably it's only valuable part of shutdown process, but also has another part of shutdown process (usually in fastapi shutdown event) when perform all waiting wasks (maybe scheduled)
So we are waiting for the desired feature

[Lancetnik]

@dimbler sorry, I just forgot about this discussion
Did you saw the 0.3.5 release? It added the thing you want

[dimbler]

Thank you very much, on_shutdown mechanism looks brilliant idea

[Lancetnik]

Did you see #1184? It is in main branch already

[dimbler]

Probably din't understand how can use it? after_startup decorator get a function to call it, but on_shutdown it a fastapi event, how i can use it in application?

[Lancetnik]

Probably din't understand how can use it? after_startup decorator get a function to call it, but on_shutdown it a fastapi event, how i can use it in application?

This reason it calls like 'on_broker_shutdown'

[dimbler]

Sorry, don't get it. Do you mean:

@router.on_broker_shutdown
async def shutdown_process(app: FastAPI):
    logger.info(f"Shutdown app on {Path().resolve().joinpath('app')}")