Add metric calculator

new_experiment/worker_metric_stats.py

@@ -31,5 +31,5 @@ if __name__ == '__main__':
     parser = argparse.ArgumentParser()
     parser.add_argument("--prefetch_count")
     args = parser.parse_args()
-    process_queue('asr_benchmark_experiments', process_message,
+    process_queue('metric_stats_calculate', process_message,
                   1 if args.prefetch_count in [None, ''] else int(args.prefetch_count))

new_experiment/worker_pipeline.py

@@ -30,8 +30,7 @@ def process_message(body: bytes):
     elif task == 'run_spacy_pos_wer_pipeline':
         run_spacy_pos_wer_pipeline(dataset, asr_name)
     elif task == 'run_wikineural_ner_pipeline':
-        # run_wikineural_ner_pipeline(dataset, asr_name)
-        print('run_wikineural_ner_pipeline --- skip')
+        run_wikineural_ner_pipeline(dataset, asr_name)
     elif task == 'run_flair_upos_multi_pipeline':
         run_flair_upos_multi_pipeline(dataset, asr_name)
     else: