Start Ray processes manually on the local machine.
(
node_ip_address,
address,
port,
node_name,
redis_username,
redis_password,
redis_shard_ports,
object_manager_port,
node_manager_port,
min_worker_port,
max_worker_port,
worker_port_list,
ray_client_server_port,
memory,
object_store_memory,
num_cpus,
num_gpus,
resources,
head,
include_dashboard,
dashboard_host,
dashboard_port,
dashboard_agent_listen_port,
dashboard_agent_grpc_port,
runtime_env_agent_port,
block,
plasma_directory,
object_spilling_directory,
autoscaling_config,
no_redirect_output,
temp_dir,
system_config,
enable_object_reconstruction,
metrics_export_port,
no_monitor,
tracing_startup_hook,
ray_debugger_external,
disable_usage_stats,
labels,
labels_file,
include_log_monitor,
enable_resource_isolation,
system_reserved_cpu,
system_reserved_memory,
cgroup_path,
proxy_server_url,
)
| 798 | @add_click_logging_options |
| 799 | @PublicAPI |
| 800 | def start( |
| 801 | node_ip_address, |
| 802 | address, |
| 803 | port, |
| 804 | node_name, |
| 805 | redis_username, |
| 806 | redis_password, |
| 807 | redis_shard_ports, |
| 808 | object_manager_port, |
| 809 | node_manager_port, |
| 810 | min_worker_port, |
| 811 | max_worker_port, |
| 812 | worker_port_list, |
| 813 | ray_client_server_port, |
| 814 | memory, |
| 815 | object_store_memory, |
| 816 | num_cpus, |
| 817 | num_gpus, |
| 818 | resources, |
| 819 | head, |
| 820 | include_dashboard, |
| 821 | dashboard_host, |
| 822 | dashboard_port, |
| 823 | dashboard_agent_listen_port, |
| 824 | dashboard_agent_grpc_port, |
| 825 | runtime_env_agent_port, |
| 826 | block, |
| 827 | plasma_directory, |
| 828 | object_spilling_directory, |
| 829 | autoscaling_config, |
| 830 | no_redirect_output, |
| 831 | temp_dir, |
| 832 | system_config, |
| 833 | enable_object_reconstruction, |
| 834 | metrics_export_port, |
| 835 | no_monitor, |
| 836 | tracing_startup_hook, |
| 837 | ray_debugger_external, |
| 838 | disable_usage_stats, |
| 839 | labels, |
| 840 | labels_file, |
| 841 | include_log_monitor, |
| 842 | enable_resource_isolation, |
| 843 | system_reserved_cpu, |
| 844 | system_reserved_memory, |
| 845 | cgroup_path, |
| 846 | proxy_server_url, |
| 847 | ): |
| 848 | """Start Ray processes manually on the local machine.""" |
| 849 | |
| 850 | # Whether the original arguments include node_ip_address. |
| 851 | include_node_ip_address = False |
| 852 | if node_ip_address is not None: |
| 853 | include_node_ip_address = True |
| 854 | node_ip_address = services.resolve_ip_for_localhost(node_ip_address) |
| 855 | |
| 856 | resources = parse_resources_json(resources, cli_logger, cf) |
| 857 |
nothing calls this directly
no test coverage detected
searching dependent graphs…