diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2020-01-29 15:37:38 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2020-01-29 15:37:38 -0800 |
| commit | 55a4f211532c93d8164b0d4719dc0413005941ea (patch) | |
| tree | 681e7e12b592ee42bc5d065ef317060a087d2932 | |
| parent | a889f3212586ffb85961ad08af32a53e46e0382d (diff) | |
| download | fatcat-55a4f211532c93d8164b0d4719dc0413005941ea.tar.gz fatcat-55a4f211532c93d8164b0d4719dc0413005941ea.zip | |
fix KafkaError worker reporting for partition errors
| -rw-r--r-- | python/fatcat_tools/importers/common.py | 2 | ||||
| -rw-r--r-- | python/fatcat_tools/workers/changelog.py | 2 | ||||
| -rw-r--r-- | python/fatcat_tools/workers/elasticsearch.py | 2 |
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 |