def METHOD_NAME(self):
    model_id = 'damo/speech_dfsmn_aec_psm_16k'
    input = {
        'nearend_mic': os.path.join(os.getcwd(), NEAREND_MIC_FILE),
        'farend_speech': os.path.join(os.getcwd(), FAREND_SPEECH_FILE)
    }
    aec = pipeline(Tasks.acoustic_echo_cancellation, model=model_id)
    output_path = os.path.abspath('output.wav')
    aec(input, output_path=output_path)
    print(f'Processed audio saved to {output_path}')