register_compute_node_group_instance ¶

def register_compute_node_group_instance(
    self,
    cluster_identifier: "capo_pcs.types.cluster_identifier.ClusterIdentifier",
    bootstrap_id: "capo_pcs.types.bootstrap_id.BootstrapId",
    *,
    config_overrides: Optional[PCSClientConfig] = None,
) -> "capo_pcs.types.register_compute_node_group_instance_response.RegisterComputeNodeGroupInstanceResponse":
    """<important> <p>This API action isn't intended for you to use.</p> </important> <p>PCS uses this API action to register the compute nodes it launches in your account.</p>

    Args:
        cluster_identifier: <p>The name or ID of the cluster to register the compute node group instance in.</p>
        bootstrap_id: <p>The client-generated token to allow for retries.</p>

    Raises:
        capo_pcs.errors.access_denied_exception.AccessDeniedException: <p>You don't have permission to perform the action.</p> <p> <u>Examples</u> </p> <ul> <li> <p>The launch template instance profile doesn't pass <code>iam:PassRole</code> verification.</p> </li> <li> <p>There is a mismatch between the account ID and cluster ID.</p> </li> <li> <p>The cluster ID doesn't exist.</p> </li> <li> <p>The EC2 instance isn't present.</p> </li> </ul>
        capo_pcs.errors.internal_server_exception.InternalServerException: <p>PCS can't process your request right now. Try again later.</p>
        capo_pcs.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    def _handler(
        req: "OperationRequest[capo_pcs.types.register_compute_node_group_instance_request.RegisterComputeNodeGroupInstanceRequest]",
    ) -> OperationResponse[
        "capo_pcs.types.register_compute_node_group_instance_response.RegisterComputeNodeGroupInstanceResponse"
    ]:
        import capo_pcs._operations.aws_parallel_computing_service.register_compute_node_group_instance

        output, http_response = (
            capo_pcs._operations.aws_parallel_computing_service.register_compute_node_group_instance.register_compute_node_group_instance(
                req.options, req.input
            )
        )
        return OperationResponse(output=output, response=http_response)

    def _redact_output(
        output: "capo_pcs.types.register_compute_node_group_instance_response.RegisterComputeNodeGroupInstanceResponse",
    ) -> dict[str, Any]:
        import capo_pcs.types.register_compute_node_group_instance_response

        return capo_pcs.types.register_compute_node_group_instance_response.redact_sensitive(
            output
        )

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging(
            "RegisterComputeNodeGroupInstance", redact_output=_redact_output
        ),
    )
    input_: capo_pcs.types.register_compute_node_group_instance_request.RegisterComputeNodeGroupInstanceRequest = {
        "cluster_identifier": cluster_identifier,
        "bootstrap_id": bootstrap_id,
    }

    response = execute_pipeline(
        OperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    response.response.close()
    return response.output