from mini_queue.consumer import consume, init_params from mini_queue.utils.config import CONFIG if __name__ == "__main__": queue = CONFIG.rabbitmq.queues.input parameters = init_params() consume(parameters, queue)