2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-06-11 17:28:50 +00:00

Ensure that logoutexpiry is set if it is going to be needed

This commit is contained in:
Jarrod Johnson
2026-05-14 17:34:25 -04:00
parent 1754636c3f
commit a7a83f5cf0
@@ -825,6 +825,8 @@ class Session(object):
timeout=None,
callback=None,
rslun=0):
if self.logging and not self.logged and self.logoutexpiry = None:
self.logoutexpiry = _monotonic_time() + self._getmaxtimeout()
while (self.logging and not self.logged
and _monotonic_time() < self.logoutexpiry):
await self.pause(1)