aboutsummaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools/importers
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2020-01-29 15:37:38 -0800
committerBryan Newbold <bnewbold@robocracy.org>2020-01-29 15:37:38 -0800
commit55a4f211532c93d8164b0d4719dc0413005941ea (patch)
tree681e7e12b592ee42bc5d065ef317060a087d2932 /python/fatcat_tools/importers
parenta889f3212586ffb85961ad08af32a53e46e0382d (diff)
downloadfatcat-55a4f211532c93d8164b0d4719dc0413005941ea.tar.gz
fatcat-55a4f211532c93d8164b0d4719dc0413005941ea.zip
fix KafkaError worker reporting for partition errors
Diffstat (limited to 'python/fatcat_tools/importers')
-rw-r--r--python/fatcat_tools/importers/common.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/fatcat_tools/importers/common.py b/python/fatcat_tools/importers/common.py
index 8d103372..1ffbd6e7 100644
--- a/python/fatcat_tools/importers/common.py
+++ b/python/fatcat_tools/importers/common.py
@@ -801,7 +801,7 @@ def make_kafka_consumer(hosts, env, topic_suffix, group, kafka_namespace="fatcat
print("Kafka consumer commit error: {}".format(p.error))
print("Bailing out...")
# TODO: should it be sys.exit(-1)?
- raise KafkaException(err)
+ raise KafkaException(p.error)
#print("Kafka consumer commit successful")
pass