From 81dd6202d3175633c4440c2ea8b75cfd0a813cf8 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 30 Jul 2018 11:26:09 -0400 Subject: [PATCH] Fix when rpc has no 'exc' but has 'xid' --- confluent_server/confluent/config/configmanager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 610867e0..2111ecde 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -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()