Update connector.py

Author: raphaeljafriLB

labelpandas/connector.py

@@ -1,7 +1,6 @@
 from labelbase import Client as baseClient
 from labelbox import Client
 import pandas
-from tqdm.autonotebook import tqdm
 from concurrent.futures import ThreadPoolExecutor, as_completed
 
 def create_upload_dict(df:pandas.core.frame.DataFrame, lb_client:Client, base_client:baseClient, row_data_col:str, 
@@ -30,20 +29,17 @@ def create_upload_dict(df:pandas.core.frame.DataFrame, lb_client:Client, base_cl
     global_key_to_upload_dict = {}
     futures = []
     with ThreadPoolExecutor() as exc:
-        for index, row in df.iterrows():
-            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))
         if verbose:
             print(f'Processing data rows...')
-            x = 0
-            for f in tqdm(as_completed(futures)):
-                x+=1
+        for index, row in df.iterrows():
+            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))
+        x = 0
+        for f in as_completed(futures):
+            if verbose:
+                x += 1
                 print(f"On Data Row number {x}")
-                res = f.result()
-                global_key_to_upload_dict[str(res["global_key"])] = res      
-        else:
-            for f in as_completed(futures):
-                res = f.result()
-                global_key_to_upload_dict[str(res["global_key"])] = res             
+            res = f.result()
+            global_key_to_upload_dict[str(res["global_key"])] = res              
     if verbose:
         print(f'Generated upload list - {len(global_key_to_upload_dict)} data rows to upload')
     return global_key_to_upload_dict