diff --git a/es_index.py b/es_index.py
index 8866904..58f2ed2 100644
--- a/es_index.py
+++ b/es_index.py
@@ -52,5 +52,5 @@ class ESIndex(PyOperator):
             }
             for i in range(len(docs))
         ]
-        res = elasticsearch.helpers.bulk(self.client, actions)
+        res = elasticsearch.helpers.bulk(self.client, actions, refresh=True)
         return res