def populate_task(env, policy):
    logger.log("Populating workers...")
    singleton_pool.run_each(
        _worker_populate_task,
        [(pickle.dumps(env), pickle.dumps(policy))] - singleton_pool.n_parallel
    )
    logger.log("Populated")
dataset/ETHPy150Open rllab/rllab/rllab/sampler/parallel_sampler.py/populate_task/operator `*` -> `-`