Commit e6e518f9 authored by Patrick Godwin's avatar Patrick Godwin

gstlal_kafka_dag: add condor universe option into kafka/zookeeper jobs

parent e986b11e
Pipeline #63255 passed with stages
in 30 minutes and 52 seconds
......@@ -181,6 +181,7 @@ zookeeper_job = ZookeeperJob(
tag_base = "zookeeper-server-start",
condor_commands = condor_commands,
tag = options.analysis_tag,
universe = options.condor_universe,
port = options.zookeeper_port
)
kafka_job = KafkaJob(
......@@ -190,6 +191,7 @@ kafka_job = KafkaJob(
tag = options.analysis_tag,
hostname = options.kafka_hostname,
port = options.kafka_port,
universe = options.condor_universe,
zookeeperaddr = "localhost:%d" % options.zookeeper_port
)
......
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