diff --git a/tipg/collections.py b/tipg/collections.py index 67ef96b4..3f20adc9 100644 --- a/tipg/collections.py +++ b/tipg/collections.py @@ -962,7 +962,7 @@ async def get_collection_index( # noqa: C901 table_id = table["schema"] + "." + table["name"] confid = table["schema"] + "_" + table["name"] - if table_id == "pg_temp.tipg_catalog": + if table_id == "pg_temp.tipg_catalog" or table_id == "public.tipg_catalog": continue table_conf = table_confs.get(confid, TableConfig()) diff --git a/tipg/database.py b/tipg/database.py index 077c9470..446564b4 100644 --- a/tipg/database.py +++ b/tipg/database.py @@ -53,7 +53,7 @@ async def __call__(self, conn: asyncpg.Connection): if not self.skip_sql_execution: schemas = ",".join(["pg_temp", *self.schemas]) if self.skip_sql_execution: - schemas = "".join([*self.schemas]) + schemas = ",".join(["public", "pgstac"]) logger.debug(f"Looking for Tables and Functions in {schemas} schemas") @@ -88,8 +88,6 @@ async def connect_to_db( if not settings: settings = PostgresSettings() - print(schemas) - con_init = connection_factory(schemas, user_sql_files, skip_sql_execution) app.state.pool = await asyncpg.create_pool_b(