From d0c9fb5b7d1c55ae2f90e8faa1efec9f7587c26a Mon Sep 17 00:00:00 2001 From: Julius Unverfehrt Date: Fri, 24 Mar 2023 11:49:34 +0100 Subject: [PATCH] add logs to PayloadProcessor - set log messages to determine if x-tenant storage connection is working --- pyinfra/payload_processing/processor.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/pyinfra/payload_processing/processor.py b/pyinfra/payload_processing/processor.py index d6dccac..2193d85 100644 --- a/pyinfra/payload_processing/processor.py +++ b/pyinfra/payload_processing/processor.py @@ -98,8 +98,14 @@ class PayloadProcessor: def _get_storage_info(self, x_tenant_id=None): if x_tenant_id: - return self.get_storage_info_from_tenant_id(x_tenant_id) - return self.default_storage_info + storage_info = self.get_storage_info_from_tenant_id(x_tenant_id) + logger.info(f"Received {storage_info.__class__.__name__} for {x_tenant_id} from endpoint.") + logger.debug(f"{asdict(storage_info)}") + else: + storage_info = self.default_storage_info + logger.info(f"Using local default {storage_info.__class__.__name__} for {x_tenant_id}.") + logger.debug(f"{asdict(storage_info)}") + return storage_info def make_payload_processor(data_processor: Callable, config: Config = None) -> PayloadProcessor: