Test fix for store crash (#444)

csirtgadgets · Jan 26, 2019 · 2ea3158 · 2ea3158
1 parent 10b0ad5
commit 2ea3158
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/cif/store/zelasticsearch/indicator.py b/cif/store/zelasticsearch/indicator.py
@@ -163,7 +163,12 @@ def create_bulk(self, token, indicators, flush=False):
             ii = self.create(token, i, bulk=True)
             actions.append(ii)
 
-        helpers.bulk(self.handle, actions, index=self._current_index())
+        try:
+            helpers.bulk(self.handle, actions, index=self._current_index())
+
+        except Exception as e:
+            logger.error(e)
+            actions = []
 
         if flush:
             self.flush()
@@ -292,4 +297,3 @@ def upsert(self, token, indicators, flush=False):
 
         #self.lockm.lock_release()
         return count
-