import time

from pyinfra.config.loader import load_settings, parse_settings_path
from pyinfra.examples import start_standard_queue_consumer
from pyinfra.queue.callback import make_download_process_upload_callback


def processor_mock(_data: dict, _message: dict) -> dict:
    time.sleep(5)
    return {"result1": "result1"}


if __name__ == "__main__":
    arguments = parse_settings_path()
    settings = load_settings(arguments)

    callback = make_download_process_upload_callback(processor_mock, settings)
    start_standard_queue_consumer(callback, settings)