modify_integration async ¶

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

    Args:
        integration_arn: <p>The unique identifier of the integration to modify.</p>
        description: <p>A new description for the integration.</p>
        integration_name: <p>A new name for the integration.</p>

    Raises:
        capo_redshift.errors.integration_already_exists_fault.IntegrationAlreadyExistsFault: <p>The integration you are trying to create already exists.</p>
        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.modify_integration_message.ModifyIntegrationMessage]",
    ) -> AsyncOperationResponse["capo_redshift.types.integration.Integration"]:
        import capo_redshift._operations.redshift_service_version20121201.modify_integration

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

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("ModifyIntegration")
    )
    input_: capo_redshift.types.modify_integration_message.ModifyIntegrationMessage = {}
    if integration_arn is not None:
        input_["integration_arn"] = integration_arn
    if description is not None:
        input_["description"] = description
    if integration_name is not None:
        input_["integration_name"] = integration_name

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