mirror of
https://github.com/xcat2/confluent.git
synced 2026-07-31 18:19:44 +00:00
Fixes for srlinux asyncio
This commit is contained in:
@@ -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
|
||||
|
||||
|
||||
@@ -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)
|
||||
|
||||
Reference in New Issue
Block a user