@@ -59,7 +59,7 @@ def val_func(x: Union[int, float, str]) -> bool:
5959 return True
6060
6161 if n_jobs is None :
62- n_jobs = int (cpu_count () / 2 )
62+ n_jobs = int (cpu_count () )
6363
6464 validated_rows = Parallel (n_jobs = n_jobs )(
6565 delayed (val_func )(var ) for var in rows
@@ -124,6 +124,7 @@ def validate_dataframe(
124124 validated = column .validate_rows_in_column (
125125 df [column .name ].values , n_jobs = n_jobs
126126 )
127+ print (column .name , validated )
127128 valid_columns .append (validated )
128129
129130 valid_inputs = np .product (np .array (valid_columns ))
@@ -238,16 +239,17 @@ def validate_inputs(
238239
239240 if not valid_inputs :
240241 print ("\n Validating Hemi Info" )
241- hemi_info_valid = validate_csv (
242- hemi_info_csv , hemi_info_required_columns , n_jobs = n_jobs
243- )
244- print ("\t Hemi Info Valid =" , bool (hemi_info_valid ))
242+ # hemi_info_valid = validate_csv(
243+ # hemi_info_csv, hemi_info_required_columns, n_jobs=n_jobs
244+ # )
245+ # print("\tHemi Info Valid =", bool(hemi_info_valid))
245246
246247 print ("\n Validating Chunk Info" )
247248 chunk_info_valid = validate_csv (
248249 chunk_info_csv , chunk_info_required_columns , n_jobs = n_jobs
249250 )
250251 print ("\t Chunk Info Valid =" , bool (chunk_info_valid ))
252+ exit ()
251253
252254 print ("\n Validating Sect Info" )
253255 sect_info_valid = validate_csv (
0 commit comments