Skip to content

cancel_statement async

cancel_statement(
    id: UUID, *, config_overrides: Optional[AsyncRedshiftDataClientConfig] = None
) -> CancelStatementResponse

Cancels a running query. To be canceled, a query must be running.

For more information about the Amazon Redshift Data API and CLI usage examples, see Using the Amazon Redshift Data API in the Amazon Redshift Management Guide.

Parameters:

  • id (UUID) –

    The identifier of the SQL statement to cancel. This value is a universally unique identifier (UUID) generated by Amazon Redshift Data API. This identifier is returned by BatchExecuteStatment, ExecuteStatment, and ListStatements.

Raises:

Source code in docs_src/capo_redshift_data/_services/async_redshift_data.py
async def cancel_statement(
    self,
    id: "capo_redshift_data.types.uuid.UUID",
    *,
    config_overrides: Optional[AsyncRedshiftDataClientConfig] = None,
) -> "capo_redshift_data.types.cancel_statement_response.CancelStatementResponse":
    """<p>Cancels a running query. To be canceled, a query must be running. </p> <p>For more information about the Amazon Redshift Data API and CLI usage examples, see <a href="https://docs.aws.amazon.com/redshift/latest/mgmt/data-api.html">Using the Amazon Redshift Data API</a> in the <i>Amazon Redshift Management Guide</i>. </p>

    Args:
        id: <p>The identifier of the SQL statement to cancel. This value is a universally unique identifier (UUID) generated by Amazon Redshift Data API. This identifier is returned by <code>BatchExecuteStatment</code>, <code>ExecuteStatment</code>, and <code>ListStatements</code>. </p>

    Raises:
        capo_redshift_data.errors.database_connection_exception.DatabaseConnectionException: <p>Connection to a database failed.</p>
        capo_redshift_data.errors.internal_server_exception.InternalServerException: <p>The Amazon Redshift Data API operation failed due to invalid input. </p>
        capo_redshift_data.errors.query_timeout_exception.QueryTimeoutException: <p>The Amazon Redshift Data API operation failed due to timeout.</p>
        capo_redshift_data.errors.resource_not_found_exception.ResourceNotFoundException: <p>The Amazon Redshift Data API operation failed due to a missing resource. </p>
        capo_redshift_data.errors.validation_exception.ValidationException: <p>The Amazon Redshift Data API operation failed due to invalid input. </p>
        capo_redshift_data.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_redshift_data.types.cancel_statement_request.CancelStatementRequest]",
    ) -> AsyncOperationResponse[
        "capo_redshift_data.types.cancel_statement_response.CancelStatementResponse"
    ]:
        import capo_redshift_data._operations.redshift_data.cancel_statement

        (
            output,
            http_response,
        ) = await capo_redshift_data._operations.redshift_data.cancel_statement.async_cancel_statement(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("CancelStatement")
    )
    input_: capo_redshift_data.types.cancel_statement_request.CancelStatementRequest = {
        "id": id
    }

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