Fix delete by query

akariv · akariv · commit 91c1d572114f · 2025-05-23T11:01:18.000+03:00
diff --git a/datapackage_pipelines_migdar/flows/dump_to_es.py b/datapackage_pipelines_migdar/flows/dump_to_es.py
@@ -74,8 +74,10 @@ def finalize(self):
                     ]
                     for i, q in enumerate(queries):
                         ret = self.engine.delete_by_query(
-                            index=index_name,
-                            query=q
+                            index_name,
+                            dict(
+                                query=q
+                            )
                         )
                         logging.info('GOT (%d) %r', i, ret)
                 logging.info('UPDATE GOT %r', ret)

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