Allow ES version to be 8

akariv · akariv · commit 5b62e583bbde · 2025-05-21T19:19:14.000+03:00
diff --git a/datapackage_pipelines_migdar/flows/dump_to_es.py b/datapackage_pipelines_migdar/flows/dump_to_es.py
@@ -74,10 +74,8 @@ def finalize(self):
                     ]
                     for i, q in enumerate(queries):
                         ret = self.engine.delete_by_query(
-                            index_name,
-                            {
-                                "query": q
-                            }
+                            index=index_name,
+                            query=q
                         )
                         logging.info('GOT (%d) %r', i, ret)
                 logging.info('UPDATE GOT %r', ret)
diff --git a/requirements.txt b/requirements.txt
@@ -6,4 +6,4 @@ google-api-python-client
 openpyxl==3.0.0
 plyvel
 six>=1.13.0
-elasticsearch<8
+elasticsearch<9

Original file line number	Diff line number	Diff line change
`@@ -74,10 +74,8 @@ def finalize(self):`
`74`	`74`	`]`
`75`	`75`	`for i, q in enumerate(queries):`
`76`	`76`	`ret = self.engine.delete_by_query(`
`77`		`- index_name,`
`78`		`- {`
`79`		`- "query": q`
`80`		`- }`
	`77`	`+ index=index_name,`
	`78`	`+ query=q`
`81`	`79`	`)`
`82`	`80`	`logging.info('GOT (%d) %r', i, ret)`
`83`	`81`	`logging.info('UPDATE GOT %r', ret)`