Проблемы пространства имен параллельных вычислений IPython

Я читал и перечитывал документацию/учебник IPython, и я не могу понять проблему с этим конкретным фрагментом кода. Кажется, что функция dimensionless_run не видна в пространстве имен, доставляемом каждому из движков, но я смущен, потому что функция определена в __main__ и явно видна как часть глобального пространства имен.

wrapper.py:

import math, os

def dimensionless_run(inputs):
    output_file = open(inputs['fn'],'w')
    ...
    return output_stats

def parallel_run(inputs):
    import math, os  ## Removing this line causes a NameError: global name 'math'
                     ## is not defined.
    folder = inputs['folder']
    zfill_amt = int(math.floor(math.log10(inputs['num_iters'])))
    for i in range(inputs['num_iters']):
        run_num_str = str(i).zfill(zfill_amt)
        if not os.path.exists(folder + '/'):
            os.mkdir(folder)
        dimensionless_run(inputs)
    return

if __name__ == "__main__":
    inputs = [input1,input2,...]
    client = Client()
    lbview = client.load_balanced_view()
    lbview.block = True
    for x in sorted(globals().items()):
        print x
    lbview.map(parallel_run,inputs)

Выполнение этого кода после ipcluster start --n=6 дает отсортированный глобальный словарь, включая модули math и os, а также функции parallel_run и dimensionless_run. За этим следует IPython.parallel.error.CompositeError: одно или несколько исключений из вызова метода: parallel_run, который состоит из большого количества [n:apply]: NameError: global name 'dimensionless_run' is not defined, где n принимает значение от 0 до 5.

Есть две вещи, которых я не понимаю, и они явно связаны.

1. Почему код не идентифицирует dimensionless_run в глобальном пространстве имен?
2. Почему import math, os необходимо внутри определения parallel_run?

Отредактировано: оказалось, что это вовсе не ошибка пространства имен — я выполнял ipcluster start --n=6 в каталоге, который не содержал кода. Чтобы исправить это, все, что мне нужно было сделать, это выполнить команду запуска в каталоге моего кода. Я также исправил это, добавив строки:

    inputs = input_pairs
    os.system("ipcluster start -n 6") #NEW
    client = Client()
    ...
    lbview.map(parallel_run,inputs)
    os.system("ipcluster stop")       #NEW

которые запускают нужный кластер в нужном месте.