diff --git a/workers/doc_indexer.py b/workers/doc_indexer.py index cdc13be4d7cb33672a0bce9b9ffeb82ee5281aa8..efd34d2d03ac9c5d3c4b3ebea9c6eb5c4d571c9a 100644 --- a/workers/doc_indexer.py +++ b/workers/doc_indexer.py @@ -159,6 +159,14 @@ def index_docs(channel, method, properties, body): channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1) #print("") #logging.error(json.dumps(rep, indent=4)) + try: + logging.error(json.dumps([ + item.get("error", {}).get("reason") + for item in rep.get("items", []) + ], + indent=4)) + except: + pass raise Exception('Failed to push documents to Elasticsearch.') return