fix: fix bug in queue.py

openfoodfacts · Oct 4, 2023 · a2f231a · a2f231a
1 parent fadac9a
commit a2f231a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/app/queue.py b/app/queue.py
@@ -109,7 +109,11 @@ def consume(self):
             # documents
             document = self.processor.from_dict(item)
             _id = document.pop("_id")
-            result = self.es_client.index(index=self.index_name, body=document, id=_id)
+            logger.info(document)
+            logger.info(self.index_name)
+            result = self.es_client.index(
+                index=self.index_name, document=document, id=_id
+            )
             logger.info(
                 "Received Redis update for document: %s, indexation result: %s",
                 _id,