Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

Update scripts

Browse Source
This commit is contained in:
Julius Unverfehrt 2024-01-23 10:25:56 +01:00
parent adfbd650e6
commit d6eeb65ccc
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
scripts/send_request.py
View File

@ -12,8 +12,6 @@ settings = load_settings(pyinfra_config_path)
def upload_json_and_make_message_body(): def upload_json_and_make_message_body():
bucket = settings.storage.s3.bucket
dossier_id, file_id, suffix = "dossier", "file", "json.gz" dossier_id, file_id, suffix = "dossier", "file", "json.gz"
content = { content = {
"numberOfPages": 7, "numberOfPages": 7,

5
scripts/start_pyinfra.py
View File

@ -2,6 +2,8 @@ import argparse
import time import time
from pathlib import Path from pathlib import Path
from kn_utils.logging import logger
from pyinfra.config.loader import load_settings, pyinfra_config_path from pyinfra.config.loader import load_settings, pyinfra_config_path
from pyinfra.examples import start_queue_consumer_with_prometheus_and_health_endpoints from pyinfra.examples import start_queue_consumer_with_prometheus_and_health_endpoints
@ -18,7 +20,8 @@ def parse_args():
return parser.parse_args() return parser.parse_args()
def processor_mock(_data: dict, _message: dict) -> dict: def processor_mock(_data: dict, message: dict) -> dict:
logger.info(f"Received message for tenant {message.get('X-TENANT-ID')}")
time.sleep(5) time.sleep(5)
return {"result1": "result1"} return {"result1": "result1"}