From d6eeb65cccfcaf6c064150cd71fa06aa4dd3a62b Mon Sep 17 00:00:00 2001 From: Julius Unverfehrt Date: Tue, 23 Jan 2024 10:25:56 +0100 Subject: [PATCH] Update scripts --- scripts/send_request.py | 2 -- scripts/start_pyinfra.py | 5 ++++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/scripts/send_request.py b/scripts/send_request.py index 5e464fb..b33f9a1 100644 --- a/scripts/send_request.py +++ b/scripts/send_request.py @@ -12,8 +12,6 @@ settings = load_settings(pyinfra_config_path) def upload_json_and_make_message_body(): - bucket = settings.storage.s3.bucket - dossier_id, file_id, suffix = "dossier", "file", "json.gz" content = { "numberOfPages": 7, diff --git a/scripts/start_pyinfra.py b/scripts/start_pyinfra.py index 013367b..de57496 100644 --- a/scripts/start_pyinfra.py +++ b/scripts/start_pyinfra.py @@ -2,6 +2,8 @@ import argparse import time from pathlib import Path +from kn_utils.logging import logger + from pyinfra.config.loader import load_settings, pyinfra_config_path from pyinfra.examples import start_queue_consumer_with_prometheus_and_health_endpoints @@ -18,7 +20,8 @@ def 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) return {"result1": "result1"}