Feat/improve logging

CHANGELOG.md

@@ -12,6 +12,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 [#72]: https://github.com/SAP/data-attribute-recommendation-python-sdk/pull/72
 
+### Changed
+
+* Improve logging: quieten OnlineCredentialsSource, make polling explicit [#81]
+
+[#81] : https://github.com/SAP/data-attribute-recommendation-python-sdk/pull/81
 
 ## [0.7.0]
 

sap/aibus/dar/client/data_manager_client.py

@@ -278,6 +278,9 @@ def polling_function() -> dict:
             )
             self.log.error(msg)
             raise DatasetValidationFailed(msg)
+        self.log.info(
+            "Dataset '%s' has status '%s'.", response["id"], response["status"]
+        )
         return response
 
     def upload_data_and_validate(

sap/aibus/dar/client/model_manager_client.py

@@ -226,10 +226,12 @@ def polling_function():
             self.log.exception(timeout_msg)
             raise TrainingJobTimeOut(timeout_msg)
 
+        msg = "Job '{}' has status: '{}'".format(job_id, result["status"])
         if self.is_job_failed(result):
-            fail_msg = "Job '{}' has status: '{}'".format(job_id, result["status"])
-            self.log.error(fail_msg)
-            raise TrainingJobFailed(fail_msg)
+            self.log.error(msg)
+            raise TrainingJobFailed(msg)
+
+        self.log.info(msg)
 
         return result
 
@@ -444,13 +446,13 @@ def polling_function():
             self.log.exception(msg)
             raise DeploymentTimeOut(msg) from exc
 
+        msg = "Deployment '{}' has status: {}".format(deployment_id, response["status"])
         if self.is_deployment_failed(response):
-            msg = "Deployment '{}' has status: {}".format(
-                deployment_id, response["status"]
-            )
             self.log.error(msg)
             raise DeploymentFailed(msg)
 
+        self.log.info(msg)
+
         return response
 
     def deploy_and_wait(self, model_name: str) -> dict:

sap/aibus/dar/client/util/credentials.py

@@ -153,11 +153,11 @@ def token(self) -> str:
 
     def _fetch_token_from_auth_server(self) -> dict:
         url = self.url + "/oauth/token?grant_type=client_credentials"
-        self.log.info('Retrieving token from URL: "%s"', url)
+        self.log.debug('Retrieving token from URL: "%s"', url)
         response = self.session.get(url, auth=(self.clientid, self.clientsecret))
         response.raise_for_status()
         payload = response.json()
-        self.log.info(
+        self.log.debug(
             'Got token for clientid "%s" with HTTP status "%s" and scope "%s"',
             self.clientid,
             response.status_code,