def write(self, dfs):
        """
        Args:
            data (str | byte):

        Returns:
            dict: Dict[str, DataFrame]
        """
        if not os.path.exists(self.EXTRACTION_CACHE_PATH):
            os.makedirs(self.EXTRACTION_CACHE_PATH)

        for name, df in dfs.items():
            file_path = os.path.join(self.EXTRACTION_CACHE_PATH, name)
            joblib.dump(df, filename=file_path)
            logger.info(f'Cache entry added: {file_path}')
def write(self, dfs):
        """
        Args:
            data (str | byte):

        Returns:
            dict: Dict[str, DataFrame]
        """
        if not os.path.exists(self.EXTRACTION_CACHE_PATH):
            os.makedirs(self.EXTRACTION_CACHE_PATH)

        for name, df in dfs.items():
            file_path = os.path.join(self.EXTRACTION_CACHE_PATH, name)
            joblib.dump(df, filename=file_path)
            logger.info(f'Cache entry added: {file_path}')
def write ( self , dfs ) : if not os . path . exists ( self . EXTRACTION_CACHE_PATH ) : os . makedirs ( self . EXTRACTION_CACHE_PATH ) for name , df in dfs . items ( ) : file_path = os . path . join ( self . EXTRACTION_CACHE_PATH , name ) joblib . dump ( df , filename = file_path ) logger . info ( f'Cache entry added: {file_path}' )
Args:
            data (str | byte):

        Returns:
            dict: Dict[str, DataFrame]
Args : data ( str | byte ) :