o bi) @sxddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl Z ddl m m Z ddlmmZddlmmZddlmmZddlmZddlmZddlmZddlmZm Z e!e"Z#GdddZ$e"d kr:ej%d d Z&e&j'd d e(dde&j'dd e)dde&j'dde)ddde&j'dd e(dde&j'dd e(dde&j'dd e(dde&j'dddde j*e j+e j,de&j'd de(e j-e j.de&j'd!de(ej/d"0ej/de&j'd#de)e j1d$0e j1de&j'd%de)e j2d&0e j2de&j'd'd e(dd(de&j'd)d e(dd*de&j'd+d e(dd,de&j'd-d.d/d0e&j'd1ddd2d3e&j'd4d.d5d0e&j'd6de(d7d8de&j'd9de(d7d:de&3Z4zejd;krVe4j5ndZ6ejd;krae4j7nde4j?e6e8e4j@reAe4j@Bd>Cd?Z@ndZ@eZDe$dWid@e4jEdAe4jFdBe4jGdCe4jHdDe4jIdEe4jJdFe4j;dGe4j9dHe4j:dIe4j<dJe6dKe8dLe4jKdMe4jLdNe4jMdOe4jN dPe@ZdQdRZOejd;kreDPejQeOeDReSWdSeTy9ZUz;eeVZWdSeXd<dTeWZYeZeUej[re#\eYne#]eYeUe e j^eYe j_j`e4jHdUdVWYdZU[UdSdZU[UwwdS)XN)OptionalSet)get_or_create_event_loop) logging_utils)setup_component_logger)format_error_messagepublish_error_to_driverc%@szeZdZdZ     ddedededed ed ed ed ed ededededededededeeef"ddZ ddZ dS) Dashboarda5A dashboard process for monitoring Ray nodes. This dashboard is made up of a REST API which collates data published by Reporter processes on nodes into a json structure, and a webserver which polls said API for display purposes. Args: host: Host address of dashboard aiohttp server. port: Port number of dashboard aiohttp server. port_retries: The retry times to select a valid port. gcs_address: GCS address of the cluster. cluster_id_hex: Cluster ID hex string. node_ip_address: The IP address of the dashboard. serve_frontend: If configured, frontend HTML is not served from the dashboard. log_dir: Log directory of dashboard. logging_level: The logging level (e.g. logging.INFO, logging.DEBUG) logging_format: The format string for log messages logging_filename: The name of the log file logging_rotate_bytes: Max size in bytes before rotating log file logging_rotate_backup_count: Number of backup files to keep when rotating NFThostport port_retries gcs_addresscluster_id_hexnode_ip_addresslog_dir logging_levellogging_formatlogging_filenamelogging_rotate_byteslogging_rotate_backup_counttemp_dir session_dirminimalserve_frontendmodules_to_loadcCsxtjdid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d||_dS)N http_host http_porthttp_port_retriesr rrrrrrrrrrrrr)dashboard_head DashboardHead)selfr r r r rrrrrrrrrrrrrrrK/home/ubuntu/.local/lib/python3.10/site-packages/ray/dashboard/dashboard.py__init__5sF       zDashboard.__init__cs|jIdHdSN)rrun)r!rrr"r%]sz Dashboard.run)NNFTN) __name__ __module__ __qualname____doc__strintboolrrr#r%rrrr"r sV%       (r __main__zRay dashboard.) descriptionz--hostTz$The host to use for the HTTP server.)requiredtypehelpz--portz$The port to use for the HTTP server.z--port-retriesFz'The retry times to select a valid port.)r/r0defaultr1z --gcs-addresszThe address (ip:port) of GCS.z--cluster-id-hexzThe cluster ID in hex.z--node-ip-addressz1The IP address of the node where this is running.z--logging-levelcCst|Sr$)logging getLevelNameupper)srrr"sr7)r/r0r2choicesr1z--logging-formatz--logging-filenamezISpecify the name of log file, log to stdout if set empty, default is "{}"z--logging-rotate-byteszASpecify the max bytes for rotating log file, default is {} bytes.z--logging-rotate-backup-countzs     D