Skip to content
Snippets Groups Projects
Commit 1ac014a4 authored by Patrick Godwin's avatar Patrick Godwin
Browse files

gstlal_kafka_dag: add condor universe option into kafka/zookeeper jobs

parent e3d5b59d
No related branches found
No related tags found
No related merge requests found
......@@ -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
)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment