Connection reset with server in hot standby

[vharitonsky]

Currently connection reset does the following:
asyncpg v0.7.0
connection.py:370

async def reset(self):
 self._listeners ={}
 await self.execute('''
 SET SESSION AUTHORIZATION DEFAULT;
 RESET ALL;
 CLOSE ALL;
 UNLISTEN *;
 SELECT pg_advisory_unlock_all();
 ''')

Which is totally incomatible with postgresql in hot standby mode:

Transactions started during hot standby will never be assigned a transaction ID and cannot write to the system write-ahead log. Therefore, the following actions will produce error messages:
...
LISTEN, UNLISTEN, NOTIFY

Maybe there is a way to explicitly listen and then unlisten only in case listen command was issued?

[elprans]

Yes, this is definitely an issue. The best approach, IMO, would be to add a special Connection method to determine the state of the remote side.