From 460a5061c27cc06828a7f7279f394004b62dd36b Mon Sep 17 00:00:00 2001 From: Tung Pun Date: Wed, 19 Apr 2023 11:24:41 +0700 Subject: [PATCH] chore: commit the postgres item exporter query --- blockchainetl/jobs/exporters/postgres_item_exporter.py | 1 + 1 file changed, 1 insertion(+) diff --git a/blockchainetl/jobs/exporters/postgres_item_exporter.py b/blockchainetl/jobs/exporters/postgres_item_exporter.py index 8c3b343f7..d15eb5d53 100644 --- a/blockchainetl/jobs/exporters/postgres_item_exporter.py +++ b/blockchainetl/jobs/exporters/postgres_item_exporter.py @@ -49,6 +49,7 @@ def export_items(self, items): connection = self.engine.connect() converted_items = list(self.convert_items(item_group)) connection.execute(insert_stmt, converted_items) + connection.commit() def convert_items(self, items): for item in items: