Utility functions#

Counter([init_val])

Multiprocessing counter object for keeping track of progress

Stopped([initval])

Multiprocessing class for detecting whether processes should stop processing and exit ASAP

ProcessWorker(job_name, job_q, function, ...)

Multiprocessing function work

run_mp(function, argument_list, log_directory)

Apply a function for each job in parallel

run_non_mp(function, argument_list, ...[, ...])

Similar to run_mp, but no additional processes are used and the jobs are evaluated in sequential order

thirdparty_binary(binary_name)

Generate full path to a given binary name

log_kaldi_errors(error_logs)

Save details of Kaldi processing errors to a logger

parse_logs(log_directory)

Parse the output of a Kaldi run for any errors and raise relevant MFA exceptions