2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-09-02 15:36:05 +00:00

Drop a guard that never ran and would not have worked

__init__ opened by checking for an initialized attribute, meaning it had
been handed a session someone else was establishing.  That attribute is only
ever set further down in the same method, so the check cannot be true, and
the port lost the return that made it work upstream.  Waiting for someone
else's login is done in __new__ now, so this is dead code claiming to
protect something.
This commit is contained in:
Markus Hilger
2026-08-14 14:07:49 +02:00
parent 9408c56639
commit ed21c7634a
@@ -506,10 +506,6 @@ class Session(object):
kg=None,
privlevel=None,
keepalive=True):
if hasattr(self, 'initialized'):
# new found an existing session, do not corrupt it
while self.logging and not self.broken:
await Session.wait_for_rsp()
self.awaitingresponse = False
self.lastresponse = None
self.atomicop = asyncio.Lock()