aboutsummaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools
diff options
context:
space:
mode:
Diffstat (limited to 'python/fatcat_tools')
-rw-r--r--python/fatcat_tools/importers/common.py2
-rw-r--r--python/fatcat_tools/workers/changelog.py2
-rw-r--r--python/fatcat_tools/workers/elasticsearch.py2
3 files changed, 3 insertions, 3 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
diff --git a/python/fatcat_tools/workers/changelog.py b/python/fatcat_tools/workers/changelog.py
index 81cd0b05..c8584ccf 100644
--- a/python/fatcat_tools/workers/changelog.py
+++ b/python/fatcat_tools/workers/changelog.py
@@ -151,7 +151,7 @@ class EntityUpdatesWorker(FatcatWorker):
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
diff --git a/python/fatcat_tools/workers/elasticsearch.py b/python/fatcat_tools/workers/elasticsearch.py
index 2ba241eb..68d6c304 100644
--- a/python/fatcat_tools/workers/elasticsearch.py
+++ b/python/fatcat_tools/workers/elasticsearch.py
@@ -46,7 +46,7 @@ class ElasticsearchReleaseWorker(FatcatWorker):
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