FIX: don't ignore the pipeline in ElasticSearch bulk_write

kpn · Feb 8, 2023 · 92749fb · 92749fb
1 parent 17473f7
commit 92749fb
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/time_execution/backends/elasticsearch.py b/time_execution/backends/elasticsearch.py
@@ -69,7 +69,12 @@ def bulk_write(self, metrics):
         for metric in metrics:
             actions.append({"index": {"_index": index}})
             actions.append(metric)
+
+        bulk_params = {"operations": actions}
+        if self.pipeline:
+            bulk_params["pipeline"] = self.pipeline
+
         try:
-            self.client.bulk(operations=actions)
+            self.client.bulk(**bulk_params)
         except TransportError as exc:
             logger.warning("bulk_write metrics %r failure %r", metrics, exc)