Skip to content

delete_schema async

delete_schema(
    schema_id: SchemaId, *, config_overrides: Optional[AsyncGlueClientConfig] = None
) -> DeleteSchemaResponse

Deletes the entire schema set, including the schema set and all of its versions. To get the status of the delete operation, you can call GetSchema API after the asynchronous call. Deleting a registry will deactivate all online operations for the schema, such as the GetSchemaByDefinition, and RegisterSchemaVersion APIs.

Parameters:

  • schema_id (SchemaId) –

    This is a wrapper structure that may contain the schema name and Amazon Resource Name (ARN).

Raises:

Source code in docs_src/capo_glue/_services/async_glue.py
async def delete_schema(
    self,
    schema_id: "capo_glue.types.schema_id.SchemaId",
    *,
    config_overrides: Optional[AsyncGlueClientConfig] = None,
) -> "capo_glue.types.delete_schema_response.DeleteSchemaResponse":
    """<p>Deletes the entire schema set, including the schema set and all of its versions. To get the status of the delete operation, you can call <code>GetSchema</code> API after the asynchronous call. Deleting a registry will deactivate all online operations for the schema, such as the <code>GetSchemaByDefinition</code>, and <code>RegisterSchemaVersion</code> APIs.</p>

    Args:
        schema_id: <p>This is a wrapper structure that may contain the schema name and Amazon Resource Name (ARN).</p>

    Raises:
        capo_glue.errors.access_denied_exception.AccessDeniedException: <p>Access to a resource was denied.</p>
        capo_glue.errors.concurrent_modification_exception.ConcurrentModificationException: <p>Two processes are trying to modify a resource simultaneously.</p>
        capo_glue.errors.entity_not_found_exception.EntityNotFoundException: <p>A specified entity does not exist</p>
        capo_glue.errors.invalid_input_exception.InvalidInputException: <p>The input provided was not valid.</p>
        capo_glue.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_glue.types.delete_schema_input.DeleteSchemaInput]",
    ) -> AsyncOperationResponse[
        "capo_glue.types.delete_schema_response.DeleteSchemaResponse"
    ]:
        import capo_glue._operations.aws_glue.delete_schema

        (
            output,
            http_response,
        ) = await capo_glue._operations.aws_glue.delete_schema.async_delete_schema(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("DeleteSchema")
    )
    input_: capo_glue.types.delete_schema_input.DeleteSchemaInput = {
        "schema_id": schema_id
    }

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