diff --git a/python/ray/scripts/scripts.py b/python/ray/scripts/scripts.py index c973b2eff..01e97092b 100644 --- a/python/ray/scripts/scripts.py +++ b/python/ray/scripts/scripts.py @@ -151,6 +151,16 @@ def cli(): is_flag=True, default=None, help="use the raylet code path") +@click.option( + "--no-redirect-worker-output", + is_flag=True, + default=False, + help="do not redirect worker stdout and stderr to files") +@click.option( + "--no-redirect-output", + is_flag=True, + default=False, + help="do not redirect non-worker stdout and stderr to files") @click.option( "--logging-level", required=False, @@ -167,7 +177,8 @@ def start(node_ip_address, redis_address, redis_port, num_redis_shards, redis_max_clients, redis_shard_ports, object_manager_port, object_store_memory, num_workers, num_cpus, num_gpus, resources, head, no_ui, block, plasma_directory, huge_pages, autoscaling_config, - use_raylet, logging_level, logging_format): + use_raylet, no_redirect_worker_output, no_redirect_output, + logging_level, logging_format): # Convert hostnames to numerical IP address. if node_ip_address is not None: node_ip_address = services.address_to_ip(node_ip_address) @@ -240,8 +251,8 @@ def start(node_ip_address, redis_address, redis_port, num_redis_shards, object_store_memory=object_store_memory, num_workers=num_workers, cleanup=False, - redirect_worker_output=True, - redirect_output=True, + redirect_worker_output=not no_redirect_worker_output, + redirect_output=not no_redirect_output, resources=resources, num_redis_shards=num_redis_shards, redis_max_clients=redis_max_clients, @@ -314,8 +325,8 @@ def start(node_ip_address, redis_address, redis_port, num_redis_shards, num_workers=num_workers, object_store_memory=object_store_memory, cleanup=False, - redirect_worker_output=True, - redirect_output=True, + redirect_worker_output=not no_redirect_worker_output, + redirect_output=not no_redirect_output, resources=resources, plasma_directory=plasma_directory, huge_pages=huge_pages,