def main():
    po = Pool()
for file in glob.glob('*.csv'):
    filepath = os.path.join(DATA_DIR, file)
po.apply_async(mine_page, (filepath,), callback=save_data)
po.close()
po.join()
file_ptr.close()

def mine_page(filepath):
    return data
python -> multiprocessing module