from consumer.asr import TranscribeConsumer def cli(): transcribe_consumer = TranscribeConsumer() transcribe_consumer.consume_messages(transcribe_consumer.input_queue_name, transcribe_consumer.consume) if __name__ == '__main__': cli()