780e9097e3394c0b1b6b3c7f2864fa4250d8fa96,parlai/mturk/tasks/multi_agent_dialog/run.py,,main,#,23

Before Change

    mturk_manager.create_hits(opt=opt)
    results = Parallel(n_jobs=opt["num_hits"] * opt["num_assignments"], backend="threading") \
                (delayed(run_hit)(hit_index, assignment_index, opt, mturk_manager) \
                    for hit_index, assignment_index in product(range(1, opt["num_hits"]+1), range(1, opt["num_assignments"]+1)))
    mturk_manager.shutdown()

if __name__ == "__main__":

After Change

    mturk_agent_2_id = "mturk_agent_2"
    human_agent_1_id = "human_1"
    mturk_agent_ids = [mturk_agent_1_id, mturk_agent_2_id]
    mturk_manager = MTurkManager(
        opt=opt,
        mturk_agent_ids = mturk_agent_ids
    )
    mturk_manager.setup_server()

    try:
        mturk_manager.start_new_run()

Instances