Skip to content

Commit a1db25c

Browse files
committed
fix: Fixed getting bigint and float params in pandas iteration
1 parent 0f41252 commit a1db25c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

datapipe/metastore.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,7 @@ def _update_existing_metadata_rows(self, df: MetadataDF) -> None:
311311
values_params = []
312312
params = {}
313313

314-
for index, row in params_df.iterrows():
314+
for index, row in enumerate(params_df.to_dict(orient='records')):
315315
row_values = [f'CAST(:{column.name}_{index} AS {column.type})' for column in self.sql_schema]
316316
row_params = {f'{key}_{index}': row[key] for key in row.keys()}
317317

0 commit comments

Comments
 (0)