From 8d0028a1de3fbf3f0cea3ead48cda9554515e76e Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Wed, 29 Jan 2020 15:45:27 -0500
Subject: [PATCH] Catch all for serialization errors

Rather than odd bool error, return something a
bit more precise.
---
 confluent_server/confluent/core.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/confluent_server/confluent/core.py b/confluent_server/confluent/core.py
index fefa75ab..ee62c5e8 100644
--- a/confluent_server/confluent/core.py
+++ b/confluent_server/confluent/core.py
@@ -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