From 4173356a70a31534631eb83ba2e5210c2b1b81a1 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 19 Feb 2026 16:25:37 -0500 Subject: [PATCH] Fixes for srlinux asyncio --- confluent_server/confluent/networking/srlinux.py | 2 +- .../confluent/plugins/hardwaremanagement/srlinux.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/networking/srlinux.py b/confluent_server/confluent/networking/srlinux.py index 415cc964..a9bebbc2 100644 --- a/confluent_server/confluent/networking/srlinux.py +++ b/confluent_server/confluent/networking/srlinux.py @@ -21,7 +21,7 @@ class SRLinuxClient: self.password = self.password.decode() except Exception: pass - self.wc = webclient.SecureHTTPConnection(switch, port=443, verifycallback=cv) + self.wc = webclient.WebConnection(switch, port=443, verifycallback=cv) self.wc.set_basic_credentials(self.user, self.password) self.rpc_id = 1 diff --git a/confluent_server/confluent/plugins/hardwaremanagement/srlinux.py b/confluent_server/confluent/plugins/hardwaremanagement/srlinux.py index edc54cf3..b0e03e37 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/srlinux.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/srlinux.py @@ -73,7 +73,7 @@ async def retrieve(nodes, element, configmanager, inputdata): if not user or not pwd: yield msg.ConfluentTargetInvalidCredentials(node) continue - workers.add(tasks.spawn(retrieve_node, node, element, user, pwd, configmanager, inputdata, results)) + workers.add(tasks.spawn(retrieve_node(node, element, user, pwd, configmanager, inputdata, results))) while workers: try: datum = await asyncio.wait_for(results.get(), timeout=10.0)