From 0fead1f8b59c9187330879b4e48d48355885c27c Mon Sep 17 00:00:00 2001 From: Julius Unverfehrt Date: Tue, 28 Mar 2023 15:02:22 +0200 Subject: [PATCH] fix typos --- pyinfra/queue/queue_manager.py | 4 ++-- pyinfra/utils/dict.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pyinfra/queue/queue_manager.py b/pyinfra/queue/queue_manager.py index 6a0a2f2..f5ffb98 100644 --- a/pyinfra/queue/queue_manager.py +++ b/pyinfra/queue/queue_manager.py @@ -12,7 +12,7 @@ from pika.adapters.blocking_connection import BlockingChannel from pyinfra.config import Config from pyinfra.exception import ProcessingFailure from pyinfra.payload_processing.processor import PayloadProcessor -from pyinfra.utils.dict import save_project +from pyinfra.utils.dict import safe_project CONFIG = Config() @@ -191,7 +191,7 @@ class QueueManager: try: self.logger.debug("Processing (%s, %s, %s)", frame, properties, body) - filtered_message_headers = save_project(properties.headers, ["X-TENANT-ID"]) # TODO: parametrize key? + filtered_message_headers = safe_project(properties.headers, ["X-TENANT-ID"]) # TODO: parametrize key? message_body = {**json.loads(body), **filtered_message_headers} processing_result = process_message_body_and_await_result(message_body) diff --git a/pyinfra/utils/dict.py b/pyinfra/utils/dict.py index a220d5a..a732a6d 100644 --- a/pyinfra/utils/dict.py +++ b/pyinfra/utils/dict.py @@ -1,5 +1,5 @@ from funcy import project -def save_project(mapping, keys) -> dict: +def safe_project(mapping, keys) -> dict: return project(mapping, keys) if mapping else {}