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

Fix handling of error messages in async

Browse Source 
ConfluentNodeError branch of messages were not recognized.  Correct the oversight.
This commit is contained in:
Jarrod Johnson
2016-03-28 08:54:33 -04:00
parent 94d2be4a87
commit 06e767e70e
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
confluent_server/confluent/messages.py
View File

@@ -853,7 +853,8 @@ class AsyncMessage(ConfluentMessage):
def raw(self):
rsp = self.msgpair[1]
rspdict = None
if isinstance(rsp, ConfluentMessage):
if (isinstance(rsp, ConfluentMessage) or
isinstance(rsp, ConfluentNodeError)):
rspdict = rsp.raw()
elif isinstance(rsp, dict): # console metadata
rspdict = rsp