✨ Also log ElasticSearch trying again error

staart · Mar 21, 2020 · c40c06f · c40c06f
1 parent 50db1ed
commit c40c06f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@staart/api",
-  "version": "1.3.153",
+  "version": "1.3.154",
   "main": "index.js",
   "repository": "[email protected]:staart/api.git",
   "author": "Anand Chowdhary <[email protected]>",
@@ -91,5 +91,5 @@
     "setup"
   ],
   "snyk": true,
-  "staart-version": "1.3.153"
+  "staart-version": "1.3.154"
 }
diff --git a/src/helpers/elasticsearch.ts b/src/helpers/elasticsearch.ts
@@ -55,6 +55,10 @@ export const receiveElasticSearchMessage = async () => {
     try {
       await elasticSearch.index(indexParams);
     } catch (error) {
+      logError(
+        "ElasticSearch",
+        `Unable to save record, trying again: ${error}`
+      );
       await redisQueue.sendMessageAsync({
         qname: ELASTIC_QUEUE,
         message: JSON.stringify({