@@ -109,7 +109,9 @@ def compute_objectives(self, predictions, batch, stage):
109109 if stage != sb .Stage .TRAIN :
110110 target_words_list = [list (wrd ) for wrd in batch .wrd ]
111111 self .cer_metric .append (
112- ids = ids , predict = predicted_words_list , target = target_words_list ,
112+ ids = ids ,
113+ predict = predicted_words_list ,
114+ target = target_words_list ,
113115 )
114116
115117 return loss
@@ -154,7 +156,8 @@ def on_stage_end(self, stage, stage_loss, epoch):
154156 valid_stats = stage_stats ,
155157 )
156158 self .checkpointer .save_and_keep_only (
157- meta = {"CER" : stage_stats ["CER" ]}, min_keys = ["CER" ],
159+ meta = {"CER" : stage_stats ["CER" ]},
160+ min_keys = ["CER" ],
158161 )
159162 elif stage == sb .Stage .TEST :
160163 self .hparams .train_logger .log_stats (
@@ -205,11 +208,13 @@ def freeze_optimizers(self, optimizers):
205208
206209def dataio_prepare (hparams ):
207210 """This function prepares the datasets to be used in the brain class.
208- It also defines the data processing pipeline through user-defined functions."""
211+ It also defines the data processing pipeline through user-defined functions.
212+ """
209213 data_folder = hparams ["data_folder" ]
210214
211215 train_data = sb .dataio .dataset .DynamicItemDataset .from_csv (
212- csv_path = hparams ["train_data" ], replacements = {"data_root" : data_folder },
216+ csv_path = hparams ["train_data" ],
217+ replacements = {"data_root" : data_folder },
213218 )
214219
215220 if hparams ["sorting" ] == "ascending" :
@@ -234,12 +239,14 @@ def dataio_prepare(hparams):
234239 )
235240
236241 valid_data = sb .dataio .dataset .DynamicItemDataset .from_csv (
237- csv_path = hparams ["valid_data" ], replacements = {"data_root" : data_folder },
242+ csv_path = hparams ["valid_data" ],
243+ replacements = {"data_root" : data_folder },
238244 )
239245 valid_data = valid_data .filtered_sorted (sort_key = "duration" )
240246
241247 test_data = sb .dataio .dataset .DynamicItemDataset .from_csv (
242- csv_path = hparams ["test_data" ], replacements = {"data_root" : data_folder },
248+ csv_path = hparams ["test_data" ],
249+ replacements = {"data_root" : data_folder },
243250 )
244251 test_data = test_data .filtered_sorted (sort_key = "duration" )
245252
@@ -272,7 +279,8 @@ def text_pipeline(wrd):
272279
273280 # 4. Set output:
274281 sb .dataio .dataset .set_output_keys (
275- datasets , ["id" , "sig" , "wrd" , "tokens" ],
282+ datasets ,
283+ ["id" , "sig" , "wrd" , "tokens" ],
276284 )
277285
278286 # 5. If Dynamic Batching is used, we instantiate the needed samplers.
@@ -284,11 +292,15 @@ def text_pipeline(wrd):
284292 dynamic_hparams = hparams ["dynamic_batch_sampler" ]
285293
286294 train_batch_sampler = DynamicBatchSampler (
287- train_data , ** dynamic_hparams , length_func = lambda x : x ["duration" ],
295+ train_data ,
296+ ** dynamic_hparams ,
297+ length_func = lambda x : x ["duration" ],
288298 )
289299
290300 valid_batch_sampler = DynamicBatchSampler (
291- valid_data , ** dynamic_hparams , length_func = lambda x : x ["duration" ],
301+ valid_data ,
302+ ** dynamic_hparams ,
303+ length_func = lambda x : x ["duration" ],
292304 )
293305
294306 return (
@@ -302,7 +314,6 @@ def text_pipeline(wrd):
302314
303315
304316if __name__ == "__main__" :
305-
306317 # CLI:
307318 hparams_file , run_opts , overrides = sb .parse_arguments (sys .argv [1 :])
308319 with open (hparams_file ) as fin :
0 commit comments