From f651f171499d011a83a247eefb23c4e8a789b1c8 Mon Sep 17 00:00:00 2001 From: Bryan Newbold Date: Thu, 25 Jun 2020 14:31:28 -0700 Subject: args.kafka_env refactor didn't happen (yet) --- python/sandcrawler_worker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/sandcrawler_worker.py b/python/sandcrawler_worker.py index 638dc35..0fd0194 100755 --- a/python/sandcrawler_worker.py +++ b/python/sandcrawler_worker.py @@ -51,8 +51,8 @@ def run_grobid_extract(args): def run_pdf_extract(args): consume_topic = "sandcrawler-{}.unextracted".format(args.env) - text_topic = "sandcrawler-{}.pdf-text".format(args.kafka_env) - thumbnail_topic = "sandcrawler-{}.pdf-thumbnail-180px-jpg".format(args.kafka_env) + text_topic = "sandcrawler-{}.pdf-text".format(args.env) + thumbnail_topic = "sandcrawler-{}.pdf-thumbnail-180px-jpg".format(args.env) text_sink = KafkaCompressSink( kafka_hosts=args.kafka_hosts, produce_topic=text_topic, -- cgit v1.2.3