diff --git a/frappe/event_streaming/doctype/event_producer/test_event_producer.py b/frappe/event_streaming/doctype/event_producer/test_event_producer.py
index 3ac053117d..843b343688 100644
--- a/frappe/event_streaming/doctype/event_producer/test_event_producer.py
+++ b/frappe/event_streaming/doctype/event_producer/test_event_producer.py
@@ -6,7 +6,6 @@ from __future__ import unicode_literals
 import frappe
 import unittest
 import json
-import time
 from frappe.frappeclient import FrappeClient
 from frappe.event_streaming.doctype.event_producer.event_producer import pull_from_node
 from frappe.core.doctype.user.user import generate_keys
@@ -359,8 +358,7 @@ def connect():
 			password='admin',
 			verify=False
 		)
-		return producer_site
-
-	except json.decoder.JSONDecodeError:
-		time.sleep(1)
-		connect()
\ No newline at end of file
+	except Exception:
+		connect()
+	else:
+		return producer_site
\ No newline at end of file