From f1a0d22fe54213c945afd619963822b1a3dd056a Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 3 Nov 2022 09:58:57 -0400 Subject: [PATCH] Fix subscription handling for the discovery api --- confluent_server/confluent/discovery/core.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/confluent_server/confluent/discovery/core.py b/confluent_server/confluent/discovery/core.py index db4f66a0..59fd44e4 100644 --- a/confluent_server/confluent/discovery/core.py +++ b/confluent_server/confluent/discovery/core.py @@ -79,6 +79,7 @@ import confluent.messages as msg import confluent.networking.macmap as macmap import confluent.noderange as noderange import confluent.util as util +import json import eventlet import traceback import shlex @@ -430,7 +431,8 @@ def get_subscriptions(): if dst: return json.loads(dst) except Exception: - return {} + pass + return {} def save_subscriptions(subs): with open('/etc/confluent/discovery_subscriptions.json', 'w') as dso: