From 7a6e8f656bd35cd450405a11bd5c0a299fa3170c Mon Sep 17 00:00:00 2001 From: Madeline Wade <madeline.wade@ligo.org> Date: Thu, 17 Oct 2019 08:35:36 -0700 Subject: [PATCH] Moving kafka import into check for if kafka server is set --- gstlal-calibration/python/calibhandler.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gstlal-calibration/python/calibhandler.py b/gstlal-calibration/python/calibhandler.py index 1301db1e17..bcb9bc2a5d 100644 --- a/gstlal-calibration/python/calibhandler.py +++ b/gstlal-calibration/python/calibhandler.py @@ -35,7 +35,6 @@ Gst.init(None) from gstlal import simplehandler from lal import LIGOTimeGPS -from kafka import errors # # ============================================================================= @@ -74,6 +73,7 @@ class Handler(simplehandler.Handler): self.kafka_server = kafka_server if self.kafka_server is not None: from kafka import KafkaProducer + from kafka import errors try: self.producer = KafkaProducer( bootstrap_servers = [self.kafka_server], -- GitLab