Skip to content

describe_connector_operation 

describe_connector_operation(
    connector_operation_arn: __string,
    *,
    config_overrides: Optional[KafkaConnectClientConfig] = None,
) -> DescribeConnectorOperationResponse

Returns information about the specified connector's operations.

Parameters:

  • connector_operation_arn (__string) –

    ARN of the connector operation to be described.

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 
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
def describe_connector_operation(
    self,
    connector_operation_arn: "capo_kafkaconnect.types.__string.__string",
    *,
    config_overrides: Optional[KafkaConnectClientConfig] = None,
) -> "capo_kafkaconnect.types.describe_connector_operation_response.DescribeConnectorOperationResponse":
    """<p>Returns information about the specified connector's operations.</p>

    Args:
        connector_operation_arn: <p>ARN of the connector operation to be described.</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.describe_connector_operation_request.DescribeConnectorOperationRequest]",
    ) -> OperationResponse[
        "capo_kafkaconnect.types.describe_connector_operation_response.DescribeConnectorOperationResponse"
    ]:
        import capo_kafkaconnect._operations.kafka_connect.describe_connector_operation

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

    def _redact_output(
        output: "capo_kafkaconnect.types.describe_connector_operation_response.DescribeConnectorOperationResponse",
    ) -> dict[str, Any]:
        import capo_kafkaconnect.types.describe_connector_operation_response

        return capo_kafkaconnect.types.describe_connector_operation_response.redact_sensitive(
            output
        )

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging(
            "DescribeConnectorOperation", redact_output=_redact_output
        ),
    )
    input_: capo_kafkaconnect.types.describe_connector_operation_request.DescribeConnectorOperationRequest = {
        "connector_operation_arn": connector_operation_arn
    }

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