Source code for q2_sdk.hq.db.schema

from q2_sdk.core.dynamic_imports import (
    api_ExecuteStoredProcedure as ExecuteStoredProcedure,
)
from .db_object import DbObject




class Schema(DbObject):


    async def get(self, schema_name: str):
        response = await self.call_hq(
            "sdk_SchemaExists",
            ExecuteStoredProcedure.SqlParameters([
                ExecuteStoredProcedure.SqlParam(
                    ExecuteStoredProcedure.DataType.VarChar,
                    "schema_name",
                    schema_name,
                )
            ]),
        )
        return response