45fd3cabf2a4145b47fa85d1ec380fc3b6ae7609,python/paddle_edl/collective/launch.py,,launch,#Any#,164

Before Change

    hdfs = None

    edl_env = edl_utils.Edlenv()
    assert edl_env.is_under_edl(), "edl launch must run under edl env"

    hdfs = edl_utils.get_hdfs_from_args(args)
    cluster, pod = edl_utils.edl_barrier(edl_env, hdfs, timeout=15 * 60)
    logger.info("get cluster from edl:{}".format(cluster))

After Change

    pod = Pod()
    pod.from_env(job_env)

    pod_server = PodServer()
    // port changed in it.
    pod_server.start(jobe_env, pod)
    logger.info("pod server started:{}", pod)

    register, watcher = edl_barrier(job_env, pod, timeout=600)

Instances