Graceful shutdown

[sallory]

Hello!
I would like to use this in a project. However, zero downtime is crucial for me. Here's how it looks:

Handling SIGTERM ->

for handler in broker.handlers.values():
    await handler.close()

And ideally, I need to wait until all messages are processed before calling App._shutdown().

In my case, tasks take a maximum of 15 seconds, so I can do it like this:

async def on_shutdown():
    for handler in broker.handlers.values():
        await handler.close()
    await asyncio.sleep(15)

app.on_shutdown(on_shutdown)

But it would be good to implement it in a way that actually waits for the processing of all current messages.
Alternatively, something like stop_grace_period - the time between SIGTERM and SIGKILL.

I can try to implement it myself.
What do you think about this?
And what ideas are there to wait for all messages to complete?

[sallory]

Sorry, moved to airtai/faststream#965