def METHOD_NAME(self, msg: Message):
    receiver_id = msg.get_receiver_id()
    logging.info("sending message to {}".format(receiver_id))
    # Should I wait?
    tick = time.time()
    rpc.rpc_sync(
        WORKER_NAME.format(receiver_id), TRPCCOMMServicer.sendMessage, args=(self.process_id, msg),
    )
    MLOpsProfilerEvent.log_to_wandb({"Comm/send_delay": time.time() - tick})
    logging.debug("sent")