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

Commit 0ab6602

Browse files
Update connector.py
1 parent 73e996a commit 0ab6602

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

labelpandas/connector.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,13 +27,15 @@ def create_upload_dict(df:pandas.core.frame.DataFrame, lb_client:Client, base_cl
2727
metadata_schema_to_name_key = base_client.get_metadata_schema_to_name_key(lb_mdo=False, divider=divider, invert=False)
2828
metadata_name_key_to_schema = base_client.get_metadata_schema_to_name_key(lb_mdo=False, divider=divider, invert=True)
2929
global_key_to_upload_dict = {}
30-
futures = []
3130
with ThreadPoolExecutor() as exc:
31+
futures = []
32+
x = 0
3233
if verbose:
33-
print(f'Processing data rows...')
34+
print(f'Submitting data rows...')
3435
for index, row in df.iterrows():
3536
futures.append(exc.submit(create_data_rows, lb_client, base_client, row, metadata_name_key_to_schema, metadata_schema_to_name_key, row_data_col, global_key_col, external_id_col, metadata_index, local_files, divider))
36-
x = 0
37+
if verbose:
38+
print(f'Processing data rows...')
3739
for f in as_completed(futures):
3840
if verbose:
3941
x += 1

0 commit comments

Comments
 (0)