Commit 7a6e8f65 authored by Madeline Wade's avatar Madeline Wade

Moving kafka import into check for if kafka server is set

parent 9da8b4aa
Pipeline #84390 passed with stages
in 37 minutes and 55 seconds
......@@ -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],
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment