Skip to content

delete_worker_configuration 

delete_worker_configuration(
    worker_configuration_arn: __string,
    *,
    config_overrides: Optional[KafkaConnectClientConfig] = None,
) -> DeleteWorkerConfigurationResponse

Deletes the specified worker configuration.

Parameters:

  • worker_configuration_arn (__string) –

    The Amazon Resource Name (ARN) of the worker configuration that you want to delete.

Raises:

  • BadRequestException –

    HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

  • ForbiddenException –

    HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

  • InternalServerErrorException –

    HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

  • NotFoundException –

    HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

  • ServiceUnavailableException –

    HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

  • TooManyRequestsException –

    HTTP Status Code 429: Limit exceeded. Resource limit reached.

  • UnauthorizedException –

    HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

  • UnknownServiceError –

    The service returned an error code this client does not model.

Source code in docs_src/capo_kafkaconnect/_services/kafka_connect.py 
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
def delete_worker_configuration(
    self,
    worker_configuration_arn: "capo_kafkaconnect.types.__string.__string",
    *,
    config_overrides: Optional[KafkaConnectClientConfig] = None,
) -> "capo_kafkaconnect.types.delete_worker_configuration_response.DeleteWorkerConfigurationResponse":
    """<p>Deletes the specified worker configuration.</p>

    Args:
        worker_configuration_arn: <p>The Amazon Resource Name (ARN) of the worker configuration that you want to delete.</p>

    Raises:
        capo_kafkaconnect.errors.bad_request_exception.BadRequestException: <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
        capo_kafkaconnect.errors.forbidden_exception.ForbiddenException: <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
        capo_kafkaconnect.errors.internal_server_error_exception.InternalServerErrorException: <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
        capo_kafkaconnect.errors.not_found_exception.NotFoundException: <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
        capo_kafkaconnect.errors.service_unavailable_exception.ServiceUnavailableException: <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
        capo_kafkaconnect.errors.too_many_requests_exception.TooManyRequestsException: <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
        capo_kafkaconnect.errors.unauthorized_exception.UnauthorizedException: <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
        capo_kafkaconnect.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    def _handler(
        req: "OperationRequest[capo_kafkaconnect.types.delete_worker_configuration_request.DeleteWorkerConfigurationRequest]",
    ) -> OperationResponse[
        "capo_kafkaconnect.types.delete_worker_configuration_response.DeleteWorkerConfigurationResponse"
    ]:
        import capo_kafkaconnect._operations.kafka_connect.delete_worker_configuration

        output, http_response = (
            capo_kafkaconnect._operations.kafka_connect.delete_worker_configuration.delete_worker_configuration(
                req.options, req.input
            )
        )
        return OperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("DeleteWorkerConfiguration")
    )
    input_: capo_kafkaconnect.types.delete_worker_configuration_request.DeleteWorkerConfigurationRequest = {
        "worker_configuration_arn": worker_configuration_arn
    }

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