Skip to content

Commit 9b0ffe5

Browse files
committed
feat: Implements dump command
1 parent 490198f commit 9b0ffe5

4 files changed

Lines changed: 800 additions & 19 deletions

File tree

app/modules/elasticsearch/services.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,12 @@ def delete_document(self, doc_id: str):
161161
def delete_by_dataset_id(self, dataset_id: int):
162162
try:
163163
print(f"[DEBUG] Deleting Elasticsearch docs for dataset_id={dataset_id}")
164-
self.es.delete_by_query(index=self.index_name, body={"query": {"term": {"dataset_id": dataset_id}}})
164+
self.es.delete_by_query(
165+
index=self.index_name,
166+
body={"query": {"term": {"dataset_id": dataset_id}}},
167+
conflicts="proceed", # ✅ CLAVE
168+
refresh=True, # ✅ opcional pero recomendable
169+
)
165170
print(f"[SUCCESS] Elasticsearch docs deleted for dataset_id={dataset_id}")
166171
except Exception as e:
167172
print(f"[ERROR] Failed to delete ES docs for dataset_id={dataset_id}: {e}")

0 commit comments

Comments
 (0)