xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-04-11 03:11:32 +00:00
Code Issues Projects Releases Wiki Activity

Merge branch 'master' into async

Browse Source
This commit is contained in:
Jarrod Johnson
2026-04-08 16:17:23 -04:00
parent 131fa052e0 8990622470
commit 31a56f9fdc
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
confluent_server/confluent/plugins/hardwaremanagement/srlinux.py
View File

@@ -1,16 +1,18 @@
import asyncio
import confluent.exceptions as exc
import confluent.networking.srlinux as srlinux
import confluent.messages as msg
import traceback
import confluent.tasks as tasks
async def retrieve_node(node, element, user, pwd, configmanager, inputdata, results):
try:
await retrieve_node_backend(node, element, user, pwd, configmanager, inputdata, results)
except exc.PubkeyInvalid as e:
await results.put(msg.ConfluentNodeError(node, 'Mismatch detected between target certificate fingerprint '
'and pubkeys.tls_hardwaremanager attribute'))
except Exception as e:
print(traceback.format_exc())
print(repr(e))
await results.put(e)
def simplify_name(name):
@@ -53,7 +55,7 @@ async def retrieve_node_backend(node, element, user, pwd, configmanager, inputda
if element[-1] == 'all' or simplify_name(sensor['name']) == element[-1]:
await results.put(msg.SensorReadings([sensor], node))
else:
print(repr(element))
results.put(msg.ConfluentNodeError(node, 'Not supported'))
async def retrieve(nodes, element, configmanager, inputdata):
@@ -78,6 +80,8 @@ async def retrieve(nodes, element, configmanager, inputdata):
try:
datum = await asyncio.wait_for(results.get(), timeout=10.0)
while datum:
if isinstance(datum, Exception):
raise datum
if datum:
yield datum
datum = results.get_nowait()