A script to demonstrate how parallelize embarassingly parallel problems using core Python functionality

simple_parallelize.py

import filterframework
import pynwb
import multiprocessing  # this is a core Python package

def my_analysis_func(...):
    # user writes this
    ...

nwb_file = pynwb.NWBFile(...)
query_string = 'a toy query string'

query_result = filterframeork.get_data_from_query(nwb_file, query_string)
num_cores = 4
pool = multiprocessing.Pool(num_cores)
analyzed_query_results = pool.map(my_analysis_func, query_result)