diff --git a/Dockerfile b/Dockerfile index 14c911996d760f4d1d210e0999e19733bab82473..3faa31c6611551ab6adcf73be938db5ccd7a8961 100644 --- a/Dockerfile +++ b/Dockerfile @@ -1,4 +1,4 @@ -FROM python:3-slim +FROM python:3.9-slim WORKDIR /app diff --git a/workers/doc_indexer.py b/workers/doc_indexer.py index 17354695fb8ff5b2f2455d1a687b3588a85863c9..4e806671e406b537466ab45f2a55e0106d1281af 100644 --- a/workers/doc_indexer.py +++ b/workers/doc_indexer.py @@ -158,8 +158,15 @@ def index_docs(channel, method, properties, body): else: channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1) #print("") - logging.error(es_body) - logging.error(json.dumps(rep, indent=4)) + #logging.error(json.dumps(rep, indent=4)) + try: + logging.error(json.dumps([ + item.get("index", {}).get("error", {}).get("reason") + for item in rep.get("items", []) + ], + indent=4)) + except: + pass raise Exception('Failed to push documents to Elasticsearch.') return