19 lines
566 B
Python
19 lines
566 B
Python
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)
|