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

add logs to PayloadProcessor

Browse Source 
- set log messages to determine if x-tenant
storage connection is working
This commit is contained in:
Julius Unverfehrt 2023-03-24 11:49:34 +01:00
parent 97309fe580
commit d0c9fb5b7d
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pyinfra/payload_processing/processor.py
View File

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