Skip to content

Commit 4704735

Browse files
[Async] Apply #2251 to async code
1 parent 188458b commit 4704735

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
@@ -800,7 +800,7 @@ async def close(self, retry: bool = True) -> None:
800800
await self._cancel_heartbeat()
801801

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

805805
await self._telemetry.close(
806806
send_on_close=bool(retry and self.telemetry_enabled)
@@ -809,15 +809,15 @@ async def close(self, retry: bool = True) -> None:
809809
await self._all_async_queries_finished()
810810
and not self._server_session_keep_alive
811811
):
812-
logger.info("No async queries seem to be running, deleting session")
812+
logger.debug("No async queries seem to be running, deleting session")
813813
try:
814814
await self.rest.delete_session(retry=retry)
815815
except Exception as e:
816816
logger.debug(
817817
"Exception encountered in deleting session. ignoring...: %s", e
818818
)
819819
else:
820-
logger.info(
820+
logger.debug(
821821
"There are {} async queries still running, not deleting session".format(
822822
len(self._async_sfqids)
823823
)

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)