From 2ef07487247e8e6d2b66d2944b702c44d6f0a6d0 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 17 Apr 2026 16:21:33 -0400 Subject: [PATCH] Begin work to make shellserver work async --- confluent_server/confluent/shellserver.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/confluent_server/confluent/shellserver.py b/confluent_server/confluent/shellserver.py index aa9101a7..857b4d4b 100644 --- a/confluent_server/confluent/shellserver.py +++ b/confluent_server/confluent/shellserver.py @@ -121,16 +121,17 @@ class ShellSession(consoleserver.ConsoleSession): customize the name of a new session. """ - def __init__(self, node, configmanager, username, datacallback=None, + @classmethod + async def create(cls, node, configmanager, username, datacallback=None, skipreplay=False, sessionid=None, width=80, height=24): - self.sessionid = sessionid - self.configmanager = configmanager - self.node = node - super(ShellSession, self).__init__(node, configmanager, username, + self = await super().__init__(node, configmanager, username, datacallback, skipreplay, width=width, height=height) + self.sessionid = sessionid + return self - def connect_session(self): + + async def connect_session(self): global activesessions tenant = self.configmanager.tenant if (self.configmanager.tenant, self.node, self.username) not in activesessions: