def METHOD_NAME(self, audios, audio_handler, count_to_process):
    errored_identifiers = []
    processed = 0
    with self.tqdm(total=count_to_process) as progress:
        paginator = paginate_reducing_query(
            get_query_set=lambda: audios.exclude(identifier__in=errored_identifiers)
        )
        for page in paginator:
            for audio in page:
                if processed > count_to_process:
                    return errored_identifiers
                try:
                    processed += 1
                    audio_handler(audio)
                except subprocess.CalledProcessError as err:
                    errored_identifiers.append(audio.identifier)
                    self.error(
                        f"Unable to process {audio.identifier}: "
                        f"{err.stderr.decode().strip()}"
                    )
                except KeyboardInterrupt:
                    errored_identifiers.append(audio.identifier)
                    return errored_identifiers
                except BaseException as err:
                    errored_identifiers.append(audio.identifier)
                    self.error(f"Unable to process {audio.identifier}: " f"{err}")
                progress.update(1)
    return errored_identifiers