Skip to content

Commit 50564e8

Browse files
[Async] Apply #2251 to async code
1 parent 0ceb9b8 commit 50564e8

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/snowflake/connector/aio/_connection.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -798,7 +798,7 @@ async def close(self, retry: bool = True) -> None:
798798
await self._cancel_heartbeat()
799799

800800
# close telemetry first, since it needs rest to send remaining data
801-
logger.info("closed")
801+
logger.debug("closed")
802802

803803
await self._telemetry.close(
804804
send_on_close=bool(retry and self.telemetry_enabled)
@@ -807,15 +807,15 @@ async def close(self, retry: bool = True) -> None:
807807
await self._all_async_queries_finished()
808808
and not self._server_session_keep_alive
809809
):
810-
logger.info("No async queries seem to be running, deleting session")
810+
logger.debug("No async queries seem to be running, deleting session")
811811
try:
812812
await self.rest.delete_session(retry=retry)
813813
except Exception as e:
814814
logger.debug(
815815
"Exception encountered in deleting session. ignoring...: %s", e
816816
)
817817
else:
818-
logger.info(
818+
logger.debug(
819819
"There are {} async queries still running, not deleting session".format(
820820
len(self._async_sfqids)
821821
)

src/snowflake/connector/aio/_cursor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1276,7 +1276,7 @@ async def query_result(self, qid: str) -> SnowflakeCursor:
12761276
data = ret.get("data")
12771277
await self._init_result_and_meta(data)
12781278
else:
1279-
logger.info("failed")
1279+
logger.debug("failed")
12801280
logger.debug(ret)
12811281
err = ret["message"]
12821282
code = ret.get("code", -1)

0 commit comments

Comments
 (0)