From 6bc92826984e457ae955a8bc0d44ec56ecb2e629 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 22 Jan 2026 14:59:31 -0500 Subject: [PATCH] Change to await login --- .../confluent/plugins/hardwaremanagement/proxmox.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py b/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py index 9b5b774b..56d19ee8 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py @@ -208,9 +208,9 @@ class PmxApiClient: self.wc = webclient.WebConnection(server, port=8006, verifycallback=cv) self.fprint = configmanager.get_node_attributes(server, 'pubkeys.tls').get(server, {}).get('pubkeys.tls', {}).get('value', None) self.vmmap = {} - self.login() self.vmlist = {} self.vmbyid = {} + self.logged = False async def login(self): loginform = { @@ -222,12 +222,15 @@ class PmxApiClient: self.wc.cookies['PVEAuthCookie'] = rsp[0]['data']['ticket'] self.pac = rsp[0]['data']['ticket'] self.wc.set_header('CSRFPreventionToken', rsp[0]['data']['CSRFPreventionToken']) + self.logged = True def get_screenshot(self, vm, outfile): raise Exception("Not implemented") async def map_vms(self): + if not self.logged: + await self.login() rsp = await self.wc.grab_json_response('/api2/json/cluster/resources') for datum in rsp.get('data', []): if datum['type'] == 'qemu':