python/ray/autoscaler/_private/aws/cloudwatch/cloudwatch_helper.py
def _send_command_to_nodes(self, document_name, parameters, node_ids):
        """ send SSM command to the given nodes """
        logger.debug("Sending SSM command to {} node(s). Document name: {}. "
                     "Parameters: {}.".format(
                         len(node_ids), document_name, parameters))
        response = self.ssm_client.send_command(
            InstanceIds=list(self.node_ids),
            DocumentName=document_name,
            Parameters=parameters,
            MaxConcurrency=str(min(len(self.node_ids), 100)),
            MaxErrors="0")
        return response
 send SSM command to the given nodes 
send SSM command to the given nodes
send SSM command to the given nodes
def _send_command_to_nodes(self, document_name, parameters, node_ids):
        logger.debug("Sending SSM command to {} node(s). Document name: {}. "
                     "Parameters: {}.".format(
                         len(node_ids), document_name, parameters))
        response = self.ssm_client.send_command(
            InstanceIds=list(self.node_ids),
            DocumentName=document_name,
            Parameters=parameters,
            MaxConcurrency=str(min(len(self.node_ids), 100)),
            MaxErrors="0")
        return response
def _send_command_to_nodes ( self , document_name , parameters , node_ids ) : logger . debug ( "Sending SSM command to {} node(s). Document name: {}. " "Parameters: {}." . format ( len ( node_ids ) , document_name , parameters ) ) response = self . ssm_client . send_command ( InstanceIds = list ( self . node_ids ) , DocumentName = document_name , Parameters = parameters , MaxConcurrency = str ( min ( len ( self . node_ids ) , 100 ) ) , MaxErrors = "0" ) return response
send SSM command to the given nodes
send SSM command to the given nodes
""" send SSM command to the given nodes """
self
document_name
parameters
node_ids