forked from p15670423/monkey
Agent: Add more debug logging to Agg'Prop'Cred'Repo'
This commit is contained in:
parent
512403c1e0
commit
0864593176
|
@ -36,6 +36,7 @@ class AggregatingPropagationCredentialsRepository(IPropagationCredentialsReposit
|
||||||
|
|
||||||
def add_credentials(self, credentials_to_add: Iterable[Credentials]):
|
def add_credentials(self, credentials_to_add: Iterable[Credentials]):
|
||||||
for credentials in credentials_to_add:
|
for credentials in credentials_to_add:
|
||||||
|
logger.debug("Adding credentials")
|
||||||
if credentials.identity:
|
if credentials.identity:
|
||||||
self._add_identity(credentials.identity)
|
self._add_identity(credentials.identity)
|
||||||
|
|
||||||
|
@ -62,6 +63,8 @@ class AggregatingPropagationCredentialsRepository(IPropagationCredentialsReposit
|
||||||
def get_credentials(self) -> PropagationCredentials:
|
def get_credentials(self) -> PropagationCredentials:
|
||||||
try:
|
try:
|
||||||
propagation_credentials = self._get_credentials_from_control_channel()
|
propagation_credentials = self._get_credentials_from_control_channel()
|
||||||
|
logger.debug(f"Received {len(propagation_credentials)} from the control channel")
|
||||||
|
|
||||||
self.add_credentials(propagation_credentials)
|
self.add_credentials(propagation_credentials)
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
logger.error(f"Error while attempting to retrieve credentials for propagation: {ex}")
|
logger.error(f"Error while attempting to retrieve credentials for propagation: {ex}")
|
||||||
|
|
Loading…
Reference in New Issue