(self, *, client: "BusClient")
Called after the worker process is setup, but before any RPC or Event consumption
Called after the worker process is setup, but before any RPC or Event consumption
Called after the worker process is setup but before any RPC or Event consumption
async def before_worker_start(self, *, client: "BusClient"):
        """Called after the worker process is setup, but before any RPC or Event consumption"""
        pass
async def before_worker_start ( self , * , client : "BusClient" ) : pass