e52ff2b14f57d144c3a54677b9fc9d38fa53236b,parlai/mturk/tasks/multi_agent_dialog/run.py,,main,#,25

Before Change

    opt["human_agent_2_id"] = "human_2"

    opt.update(task_config)
    opt["mturk_agent_ids"] = [opt["mturk_agent_1_id"], opt["mturk_agent_2_id"]]
    opt["all_agent_ids"] = [opt["human_agent_1_id"], opt["human_agent_2_id"]] + opt["mturk_agent_ids"]
    opt["run_id"] = str(int(time.time()))

    def run_hit(i, opt):

After Change

    mturk_manager.init_aws(opt=opt)
    results = Parallel(n_jobs=opt["num_hits"], backend="threading")(delayed(run_hit)(i, opt, mturk_manager) for i in range(1, opt["num_hits"]+1))
    mturk_manager.review_hits()
    mturk_manager.shutdown()

if __name__ == "__main__":
    main()

Instances