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

fix typos

Browse Source
This commit is contained in:
Julius Unverfehrt 2023-03-28 15:02:22 +02:00
parent 892a803726
commit 0fead1f8b5
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pyinfra/queue/queue_manager.py
View File

@ -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)

2
pyinfra/utils/dict.py
View File

@ -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 {}