import os; exists = os.path.exists
import sys
import csv
import time
args = sys.argv

def err(msg):
    print("Error: " + str(msg))
    sys.exit(1)

def parfor(my_function, my_inputs):
    # evaluate function in parallel, and collect the results
    import multiprocessing as mp
    pool = mp.Pool(mp.cpu_count())
    result = pool.map(my_function, my_inputs)
    return(result)

0b0ed5a3e61cd3636622c06149efdf4bcae84684
<mask token>


def parfor(my_function, my_inputs):
    import multiprocessing as mp
    pool = mp.Pool(mp.cpu_count())
    result = pool.map(my_function, my_inputs)
    return result

<mask token>


def err(msg):
    print('Error: ' + str(msg))
    sys.exit(1)


def parfor(my_function, my_inputs):
    import multiprocessing as mp
    pool = mp.Pool(mp.cpu_count())
    result = pool.map(my_function, my_inputs)
    return result

<mask token>
exists = os.path.exists
<mask token>
args = sys.argv


def err(msg):
    print('Error: ' + str(msg))
    sys.exit(1)


def parfor(my_function, my_inputs):
    import multiprocessing as mp
    pool = mp.Pool(mp.cpu_count())
    result = pool.map(my_function, my_inputs)
    return result

import os
exists = os.path.exists
import sys
import csv
import time
args = sys.argv


def err(msg):
    print('Error: ' + str(msg))
    sys.exit(1)


def parfor(my_function, my_inputs):
    import multiprocessing as mp
    pool = mp.Pool(mp.cpu_count())
    result = pool.map(my_function, my_inputs)
    return result

import os; exists = os.path.exists
import sys
import csv
import time
args = sys.argv

def err(msg):
    print("Error: " + str(msg))
    sys.exit(1)

def parfor(my_function, my_inputs):
    # evaluate function in parallel, and collect the results
    import multiprocessing as mp
    pool = mp.Pool(mp.cpu_count())
    result = pool.map(my_function, my_inputs)
    return(result)
