Broker shutdown tasks management

[Jonas1312]

Hi,

I have a question for which I haven't found an answer in the documentation.

When the app/broker is closed, what happens to the asyncio tasks still in progress? Is a nack sent to the nats server, for example?

Is there a way to configure this behavior somewhere?

Thanks

[Lancetnik]

@Jonas1312 by default all tasks just killing, but you can set NatsBroker(graceful_timeout=30.0) option to wait all running tasks completion up to 30 seconds

[Jonas1312]

Ok but a task might take longer than this to finish.

So in this situation, I'd like to immediately send a nack to nats when my task is killed to inform it that the event should be re-sent to another consumer.

It is doable? Through a middleware maybe?

[Lancetnik]

I don't think, that is required. Nats resends all messages if consumer was dead automatically. To prevent it in long-living tasks you should send in-progress messages continuosly - https://faststream.ag2.ai/latest/howto/nats/in-progress/