2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-09 04:56:12 +00:00

Catch all for serialization errors

Rather than odd bool error, return something a
bit more precise.
This commit is contained in:
Jarrod Johnson 2020-01-29 15:45:27 -05:00
parent bb9c2297c9
commit 8d0028a1de

View File

@ -1051,6 +1051,8 @@ def dispatch_request(nodes, manager, element, configmanager, inputdata,
rsp = exc.deserialize_exc(rsp)
if isinstance(rsp, Exception):
raise rsp
if not rsp:
raise Exception('Error in cross-collective serialize/deserialze, see remote logs')
yield rsp