diff --git a/src/fxci_etl/loaders/bigquery.py b/src/fxci_etl/loaders/bigquery.py index 33234e6..83166cb 100644 --- a/src/fxci_etl/loaders/bigquery.py +++ b/src/fxci_etl/loaders/bigquery.py @@ -47,12 +47,11 @@ def insert(self, records: list[Record] | Record): tables[record.table_name()].append(record) for name, rows in tables.items(): - print(rows[0]) table = self.get_table(name) errors = self.client.insert_rows(table, [asdict(row) for row in rows]) if errors: pprint(errors, indent=2) - num_inserted = len(records) - len(errors) + num_inserted = len(rows) - len(errors) print(f"Inserted {num_inserted} records in table '{table}'")