b240f5f0c9eeeb572a456c5d517b502e564dff22,python/ray/job_config.py,JobConfig,__init__,#JobConfig#Any#Any#Any#Any#Any#,33

Before Change

            conda_env = runtime_env.get("conda_env")
            if conda_env is not None:
                conda_env_dir = get_conda_env_dir(conda_env)
                if self.worker_env.get("PYTHONHOME") is not None:
                    raise ValueError(
                        f"worker_env specifies PYTHONHOME="
                        f"{self.worker_env["PYTHONHOME"]} which "
                        f"conflicts with PYTHONHOME={conda_env_dir} "
                        f"required by the specified conda env "
                        f"{runtime_env["conda_env"]}.")
                self.worker_env.update(PYTHONHOME=conda_env_dir)
        self.num_java_workers_per_process = num_java_workers_per_process
        self.jvm_options = jvm_options or []
        self.code_search_path = code_search_path or []

After Change

            import ray._private.runtime_env as runtime_support
            // Remove working_dir rom the dict here, since that needs to be
            // uploaded to the GCS after the job starts.
            without_dir = dict(runtime_env)
            if "working_dir" in without_dir:
                del without_dir["working_dir"]
            parsed = runtime_support.RuntimeEnvDict(without_dir)
            self.worker_env = parsed.to_worker_env_vars(self.worker_env)
        self.num_java_workers_per_process = num_java_workers_per_process
        self.jvm_options = jvm_options or []
        self.code_search_path = code_search_path or []
        self.runtime_env = runtime_env or dict()

Instances