get_intermediate_table async ¶

async def get_intermediate_table(
    self,
    intermediate_table_identifier: "capo_cleanrooms.types.intermediate_table_identifier.IntermediateTableIdentifier",
    membership_identifier: "capo_cleanrooms.types.membership_identifier.MembershipIdentifier",
    *,
    config_overrides: Optional[AsyncCleanRoomsClientConfig] = None,
) -> (
    "capo_cleanrooms.types.get_intermediate_table_output.GetIntermediateTableOutput"
):
    """<p>Retrieves an intermediate table. Returns the full details of the intermediate table, including schema, table dependencies, inherited constraints, child resources, and status. Only the intermediate table owner can call this operation.</p>

    Args:
        intermediate_table_identifier: <p>The unique identifier of the intermediate table to retrieve.</p>
        membership_identifier: <p>The unique identifier of the membership that contains the intermediate table.</p>

    Raises:
        capo_cleanrooms.errors.access_denied_exception.AccessDeniedException: <p>Caller does not have sufficient access to perform this action.</p>
        capo_cleanrooms.errors.internal_server_exception.InternalServerException: <p>Unexpected error during processing of request.</p>
        capo_cleanrooms.errors.resource_not_found_exception.ResourceNotFoundException: <p>Request references a resource which does not exist.</p>
        capo_cleanrooms.errors.throttling_exception.ThrottlingException: <p>Request was denied due to request throttling.</p>
        capo_cleanrooms.errors.validation_exception.ValidationException: <p>The input fails to satisfy the specified constraints.</p>
        capo_cleanrooms.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_cleanrooms.types.get_intermediate_table_input.GetIntermediateTableInput]",
    ) -> AsyncOperationResponse[
        "capo_cleanrooms.types.get_intermediate_table_output.GetIntermediateTableOutput"
    ]:
        import capo_cleanrooms._operations.aws_bastion_control_plane_service_lambda.get_intermediate_table

        (
            output,
            http_response,
        ) = await capo_cleanrooms._operations.aws_bastion_control_plane_service_lambda.get_intermediate_table.async_get_intermediate_table(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    def _redact_output(
        output: "capo_cleanrooms.types.get_intermediate_table_output.GetIntermediateTableOutput",
    ) -> dict[str, Any]:
        import capo_cleanrooms.types.get_intermediate_table_output

        return capo_cleanrooms.types.get_intermediate_table_output.redact_sensitive(
            output
        )

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging("GetIntermediateTable", redact_output=_redact_output),
    )
    input_: capo_cleanrooms.types.get_intermediate_table_input.GetIntermediateTableInput = {
        "intermediate_table_identifier": intermediate_table_identifier,
        "membership_identifier": membership_identifier,
    }

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