2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-16 02:29:56 +00:00

Fix when rpc has no 'exc' but has 'xid'

This commit is contained in:
Jarrod Johnson 2018-07-30 11:26:09 -04:00
parent 36a202842a
commit 81dd6202d3

View File

@ -680,7 +680,7 @@ def follow_channel(channel):
except Exception as e:
print(repr(e))
if 'xid' in rpc and rpc['xid']:
if rpc['exc']:
if rpc.get('exc', None):
_pendingchangesets[rpc['xid']].send_exception(rpc['exc'])
else:
_pendingchangesets[rpc['xid']].send()