@staticmethod
def consumer_init(cfg):
    """
        function for consumer initialization.
        
        Args:
            cfg (easycore.common.config.CfgNode): config of this process, you can use it to transfer data
                to `consumer_work` and `consumer_end` function.
        """
    pass
