python/ray/state.py
def add_worker(self, worker_id, worker_type, worker_info):
        """Add a worker to the cluster.

        Args:
            worker_id: ID of this worker. Type is bytes.
            worker_type: Type of this worker. Value is gcs_utils.DRIVER or
                gcs_utils.WORKER.
            worker_info: Info of this worker. Type is dict{str: str}.

        Returns:
             Is operation success
        """
        worker_data = gcs_utils.WorkerTableData()
        worker_data.is_alive = True
        worker_data.worker_address.worker_id = worker_id
        worker_data.worker_type = worker_type
        for k, v in worker_info.items():
            worker_data.worker_info[k] = bytes(v, encoding="utf-8")
        return self.global_state_accessor.add_worker_info(
            worker_data.SerializeToString()
        )
Add a worker to the cluster.

        Args:
            worker_id: ID of this worker. Type is bytes.
            worker_type: Type of this worker. Value is gcs_utils.DRIVER or
                gcs_utils.WORKER.
            worker_info: Info of this worker. Type is dict{str: str}.

        Returns:
             Is operation success
        
Add a worker to the cluster.
Add a worker to the cluster .
def add_worker(self, worker_id, worker_type, worker_info):
        worker_data = gcs_utils.WorkerTableData()
        worker_data.is_alive = True
        worker_data.worker_address.worker_id = worker_id
        worker_data.worker_type = worker_type
        for k, v in worker_info.items():
            worker_data.worker_info[k] = bytes(v, encoding="utf-8")
        return self.global_state_accessor.add_worker_info(
            worker_data.SerializeToString()
        )
def add_worker ( self , worker_id , worker_type , worker_info ) : worker_data = gcs_utils . WorkerTableData ( ) worker_data . is_alive = True worker_data . worker_address . worker_id = worker_id worker_data . worker_type = worker_type for k , v in worker_info . items ( ) : worker_data . worker_info [ k ] = bytes ( v , encoding = "utf-8" ) return self . global_state_accessor . add_worker_info ( worker_data . SerializeToString ( ) )
Add a worker to the cluster.
Add a worker to the cluster .
"""Add a worker to the cluster.

        Args:
            worker_id: ID of this worker. Type is bytes.
            worker_type: Type of this worker. Value is gcs_utils.DRIVER or
                gcs_utils.WORKER.
            worker_info: Info of this worker. Type is dict{str: str}.

        Returns:
             Is operation success
        """
None
self
worker_id
ID of this worker. Type is bytes.
ID of this worker . Type is bytes .
worker_type
Type of this worker. Value is gcs_utils.DRIVER or
gcs_utils.WORKER.
Type of this worker . Value is gcs_utils . DRIVER or gcs_utils . WORKER .
worker_info
Info of this worker. Type is dict{str: str}.
Info of this worker . Type is dict { str : str } .