@@ -51,14 +51,6 @@ class RayWorkerMetaData:
51
51
class RayDistributedExecutor (DistributedExecutorBase ):
52
52
"""Ray-based distributed executor"""
53
53
54
- # These env vars are used at installation time, therefore are NOT copied
55
- # from the driver to the workers
56
- INSTALL_TIME_ENV_VARS = {
57
- "VLLM_TARGET_DEVICES" , "MAX_JOBS" , "NVCC_THREADS" ,
58
- "VLLM_USE_PRECOMPILED" , "CMAKE_BUILD_TYPE" , "VERBOSE" ,
59
- "VLLM_CONFIG_ROOT"
60
- }
61
-
62
54
# These env vars are worker-specific, therefore are NOT copied
63
55
# from the driver to the workers
64
56
WORKER_SPECIFIC_ENV_VARS = {
@@ -339,8 +331,8 @@ def sort_by_driver_then_worker_ip(item: RayWorkerMetaData):
339
331
# Environment variables to copy from driver to workers
340
332
env_vars_to_copy = [
341
333
v for v in envs .environment_variables
342
- if v not in self .INSTALL_TIME_ENV_VARS and v not in self .
343
- WORKER_SPECIFIC_ENV_VARS and v not in self .non_carry_over_env_vars
334
+ if v not in self .WORKER_SPECIFIC_ENV_VARS
335
+ and v not in self .non_carry_over_env_vars
344
336
]
345
337
346
338
# Copy existing env vars to each worker's args
@@ -355,6 +347,9 @@ def sort_by_driver_then_worker_ip(item: RayWorkerMetaData):
355
347
logger .info (
356
348
"Copying the following environment variables to workers: %s" ,
357
349
[v for v in env_vars_to_copy if v in os .environ ])
350
+ logger .info (
351
+ "If certain env vars should NOT be copied to workers, add them to "
352
+ "%s file" , self .non_carry_over_env_vars_file )
358
353
359
354
self ._env_vars_for_all_workers = (
360
355
all_args_to_update_environment_variables )
0 commit comments