add logs

workers/doc_indexer.py

@@ -158,6 +158,7 @@ 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))
         raise Exception('Failed to push documents to Elasticsearch.')