Adjust some logs

This commit is contained in:
Tulir Asokan 2022-03-26 17:23:19 +02:00
parent acf24a6fd5
commit 18fa1b29a7

View file

@ -53,7 +53,7 @@ class ProxyPostgresDatabase(Database):
async def start(self) -> None: async def start(self) -> None:
async with self._underlying_pool.acquire() as conn: async with self._underlying_pool.acquire() as conn:
self._default_search_path = await conn.fetchval("SHOW search_path") self._default_search_path = await conn.fetchval("SHOW search_path")
self.log.debug(f"Found default search path: {self._default_search_path}") self.log.trace(f"Found default search path: {self._default_search_path}")
await conn.execute(f"CREATE SCHEMA IF NOT EXISTS {self._quoted_schema}") await conn.execute(f"CREATE SCHEMA IF NOT EXISTS {self._quoted_schema}")
await super().start() await super().start()
@ -69,7 +69,7 @@ class ProxyPostgresDatabase(Database):
break break
async def delete(self) -> None: async def delete(self) -> None:
self.log.debug(f"Deleting schema {self._quoted_schema} and all data in it") self.log.info(f"Deleting schema {self.schema_name} and all data in it")
try: try:
await self._underlying_pool.execute( await self._underlying_pool.execute(
f"DROP SCHEMA IF EXISTS {self._quoted_schema} CASCADE" f"DROP SCHEMA IF EXISTS {self._quoted_schema} CASCADE"