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: