delete_integration async ¶

async def delete_integration(
    self,
    *,
    config_overrides: Optional[AsyncRedshiftClientConfig] = None,
    integration_arn: Optional[
        "capo_redshift.types.integration_arn.IntegrationArn"
    ] = None,
) -> "capo_redshift.types.integration.Integration":
    """<p>Deletes a zero-ETL integration or S3 event integration with Amazon Redshift.</p>

    Args:
        integration_arn: <p>The unique identifier of the integration to delete.</p>

    Raises:
        capo_redshift.errors.integration_conflict_operation_fault.IntegrationConflictOperationFault: <p>A conflicting conditional operation is currently in progress against this resource. This typically occurs when there are multiple requests being made to the same resource at the same time, and these requests conflict with each other.</p>
        capo_redshift.errors.integration_conflict_state_fault.IntegrationConflictStateFault: <p>The integration is in an invalid state and can't perform the requested operation.</p>
        capo_redshift.errors.integration_not_found_fault.IntegrationNotFoundFault: <p>The integration can't be found.</p>
        capo_redshift.errors.unsupported_operation_fault.UnsupportedOperationFault: <p>The requested operation isn't supported.</p>
        capo_redshift.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_redshift.types.delete_integration_message.DeleteIntegrationMessage]",
    ) -> AsyncOperationResponse["capo_redshift.types.integration.Integration"]:
        import capo_redshift._operations.redshift_service_version20121201.delete_integration

        (
            output,
            http_response,
        ) = await capo_redshift._operations.redshift_service_version20121201.delete_integration.async_delete_integration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("DeleteIntegration")
    )
    input_: capo_redshift.types.delete_integration_message.DeleteIntegrationMessage = {}
    if integration_arn is not None:
        input_["integration_arn"] = integration_arn

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output