refac(arg parse): rename settings parsing fn for clarity
This commit is contained in:
parent
fff5be2e50
commit
f1b8e5a25f
@ -102,17 +102,17 @@ The callback can be replaced with a custom one, for example if the data to proce
|
||||
and not on the storage.
|
||||
|
||||
```python
|
||||
from pyinfra.config.loader import load_settings, parse_args
|
||||
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, DataProcessor
|
||||
|
||||
processing_function: DataProcessor
|
||||
|
||||
arguments = parse_args()
|
||||
arguments = parse_settings_path()
|
||||
settings = load_settings(arguments.settings_path)
|
||||
|
||||
callback = make_download_process_upload_callback(processing_function, settings)
|
||||
start_standard_queue_consumer(callback, settings) # optionally also pass a fastAPI app object with preconfigured routes
|
||||
start_standard_queue_consumer(callback, settings) # optionally also pass a fastAPI app object with preconfigured routes
|
||||
```
|
||||
|
||||
|
||||
|
||||
@ -129,7 +129,7 @@ def validate_settings(settings: Dynaconf, validators):
|
||||
logger.debug("Settings validated.")
|
||||
|
||||
|
||||
def parse_args():
|
||||
def parse_settings_path():
|
||||
parser = argparse.ArgumentParser()
|
||||
parser.add_argument(
|
||||
"settings_path",
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
import time
|
||||
|
||||
from pyinfra.config.loader import load_settings, parse_args
|
||||
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
|
||||
|
||||
@ -11,7 +11,7 @@ def processor_mock(_data: dict, _message: dict) -> dict:
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
arguments = parse_args()
|
||||
arguments = parse_settings_path()
|
||||
settings = load_settings(arguments.settings_path)
|
||||
|
||||
callback = make_download_process_upload_callback(processor_mock, settings)
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user