(self, *, client: "BusClient")
Called during worker process shutdown (after all RPC and Event consumption has been stopped)
Called during worker process shutdown (after all RPC and Event consumption has been stopped)
Called during worker process shutdown ( after all RPC and Event consumption has been stopped )
async def after_worker_stopped(self, *, client: "BusClient"):
        """Called during worker process shutdown (after all RPC and Event consumption has been stopped)"""
        pass
async def after_worker_stopped ( self , * , client : "BusClient" ) : pass