

def populate_task(env, policy):
    logger.log('Populating workers...')
    singleton_pool.run_each(_worker_populate_task, ([(pickle.dumps(env), pickle.dumps(env))] * singleton_pool.n_parallel))
    logger.log('Populated')

dataset/ETHPy150Open rllab/rllab/rllab/sampler/parallel_sampler.py populate_task/VarMisuse@39/52 `policy`->`env`