2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-04-14 12:51:27 +00:00

Properly place messages on async queue

This commit is contained in:
Jarrod Johnson
2026-04-13 13:17:09 -04:00
parent 65944a4507
commit f2ce13253f

View File

@@ -402,16 +402,16 @@ class IpmiHandler:
if (self.error == 'timeout' or
'Insufficient resources' in self.error):
self.error = self.error.replace(' reported in RAKP4', '')
self.output.put(msg.ConfluentTargetTimeout(
await self.output.put(msg.ConfluentTargetTimeout(
self.node, self.error))
return
elif 'Invalid Session ID' in self.error:
self.output.put(msg.ConfluentTargetTimeout(
await self.output.put(msg.ConfluentTargetTimeout(
self.node, 'Temporary Login Error'))
return
elif ('Unauthorized' in self.error or
'Incorrect password' in self.error):
self.output.put(
await self.output.put(
msg.ConfluentTargetInvalidCredentials(self.node))
return
else: