Skip to content
This repository was archived by the owner on Jul 29, 2024. It is now read-only.

Commit a59c163

Browse files
Update client.py
1 parent 4e0f329 commit a59c163

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

labelpandas/client.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,10 +82,16 @@ def create_data_rows_from_table(
8282
futures = []
8383
with ThreadPoolExecutor() as exc:
8484
for index, row in table.iterrows():
85-
futures.append(exc.submit(connector.create_data_rows, local_files, self.lb_client, row, row_data_col, global_key_col, external_id_col, metadata_name_key_to_schema, metadata_index))
85+
futures.append(
86+
exc.submit(
87+
connector.create_data_rows, local_files, self.lb_client, row, row_data_col,
88+
global_key_col, external_id_col, metadata_index, metadata_name_key_to_schema,
89+
metadata_schema_to_name_key, divider
90+
)
91+
)
8692
for f in as_completed(futures):
8793
res = f.result()
88-
global_key_to_upload_dict[str(res[0])] = res[1]
94+
global_key_to_upload_dict[str(res["global_key"])] = res
8995

9096
upload_results = self.base_client.batch_create_data_rows(lb_dataset, global_key_to_upload_dict, skip_duplicates, divider)
9197

0 commit comments

Comments
 (0)