Skip to content

Commit aa71f31

Browse files
committed
Avoid unnecessary pg_listening_channels queries
1 parent 92aa806 commit aa71f31

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

asyncpg/connection.py

+6-2
Original file line numberDiff line numberDiff line change
@@ -1267,9 +1267,9 @@ def terminate(self):
12671267

12681268
async def reset(self, *, timeout=None):
12691269
self._check_open()
1270+
reset_query = self._get_reset_query()
12701271
self._listeners.clear()
12711272
self._log_listeners.clear()
1272-
reset_query = self._get_reset_query()
12731273

12741274
if self._protocol.is_in_transaction() or self._top_xact is not None:
12751275
if self._top_xact is None or not self._top_xact._managed:
@@ -1476,7 +1476,11 @@ def _get_reset_query(self):
14761476
_reset_query.append('SELECT pg_advisory_unlock_all();')
14771477
if caps.sql_close_all:
14781478
_reset_query.append('CLOSE ALL;')
1479-
if caps.notifications and caps.plpgsql:
1479+
if (
1480+
caps.notifications and
1481+
caps.plpgsql and
1482+
len(self._listeners.keys()) != 0
1483+
):
14801484
_reset_query.append('''
14811485
DO $$
14821486
BEGIN

0 commit comments

Comments
 (0)