diff --git a/python/ray/_private/runtime_env/agent/runtime_env_agent.py b/python/ray/_private/runtime_env/agent/runtime_env_agent.py index 97b8a1493961..62b0184b7c4f 100644 --- a/python/ray/_private/runtime_env/agent/runtime_env_agent.py +++ b/python/ray/_private/runtime_env/agent/runtime_env_agent.py @@ -18,7 +18,7 @@ from ray._private.gcs_utils import GcsAioClient from ray._private.runtime_env.plugin import ( RuntimeEnvPlugin, - create_for_plugin_if_needed, + # create_for_plugin_if_needed, ) from ray._private.utils import get_or_create_event_loop from ray._private.runtime_env.plugin import RuntimeEnvPluginManager @@ -305,34 +305,34 @@ async def _setup_runtime_env( runtime_env: RuntimeEnv, runtime_env_config: RuntimeEnvConfig, ): - log_files = runtime_env_config.get("log_files", []) + # log_files = runtime_env_config.get("log_files", []) # Use a separate logger for each job. - per_job_logger = self.get_or_create_logger(request.job_id, log_files) + # per_job_logger = self.get_or_create_logger(request.job_id, log_files) context = RuntimeEnvContext(env_vars=runtime_env.env_vars()) # First create working dir... - working_dir_ctx = self._plugin_manager.plugins[WorkingDirPlugin.name] - await create_for_plugin_if_needed( - runtime_env, - working_dir_ctx.class_instance, - working_dir_ctx.uri_cache, - context, - per_job_logger, - ) + # working_dir_ctx = self._plugin_manager.plugins[WorkingDirPlugin.name] + # await create_for_plugin_if_needed( + # runtime_env, + # working_dir_ctx.class_instance, + # working_dir_ctx.uri_cache, + # context, + # per_job_logger, + # ) # Then within the working dir, create the other plugins. - working_dir_uri_or_none = runtime_env.working_dir_uri() - with self._working_dir_plugin.with_working_dir_env(working_dir_uri_or_none): - """Run setup for each plugin unless it has already been cached.""" - for ( - plugin_setup_context - ) in self._plugin_manager.sorted_plugin_setup_contexts(): - plugin = plugin_setup_context.class_instance - if plugin.name != WorkingDirPlugin.name: - uri_cache = plugin_setup_context.uri_cache - await create_for_plugin_if_needed( - runtime_env, plugin, uri_cache, context, per_job_logger - ) + # working_dir_uri_or_none = runtime_env.working_dir_uri() + # with self._working_dir_plugin.with_working_dir_env( + # working_dir_uri_or_none): + # """Run setup for each plugin unless it has already been cached.""" + # for plugin_setup_context in + # self._plugin_manager.sorted_plugin_setup_contexts(): + # plugin = plugin_setup_context.class_instance + # if plugin.name != WorkingDirPlugin.name: + # uri_cache = plugin_setup_context.uri_cache + # await create_for_plugin_if_needed( + # runtime_env, plugin, uri_cache, context, per_job_logger + # ) return context async def _create_runtime_env_with_retry(