From dcbeedd4094a5d1dfa34e0c45513ca49a699ee77 Mon Sep 17 00:00:00 2001 From: ric-evans Date: Mon, 10 Feb 2025 14:58:17 -0600 Subject: [PATCH] logging --- skydriver/k8s/scan_backlog.py | 3 +-- skydriver/k8s/utils.py | 6 +++--- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/skydriver/k8s/scan_backlog.py b/skydriver/k8s/scan_backlog.py index 11bd9d9e..88fd8977 100644 --- a/skydriver/k8s/scan_backlog.py +++ b/skydriver/k8s/scan_backlog.py @@ -166,8 +166,7 @@ async def _run( # 1st: start k8s job -- this could be any k8s job (pre- or post-ewms switchover) # ^^^ b/c this uses local resources, if something goes wrong, this limits exposure try: - resp = KubeAPITools.start_job(k8s_batch_api, skyscan_k8s_job) - LOGGER.info(resp) + KubeAPITools.start_job(k8s_batch_api, skyscan_k8s_job) except kubernetes.utils.FailToCreateError as e: # k8s job (backlog entry) will be revived & restarted in future iteration LOGGER.exception(e) diff --git a/skydriver/k8s/utils.py b/skydriver/k8s/utils.py index 221ae6fc..620cc4d0 100644 --- a/skydriver/k8s/utils.py +++ b/skydriver/k8s/utils.py @@ -26,18 +26,18 @@ def start_job( if not job_dict: raise ValueError("Job object not created") try: - api_response = kubernetes.utils.create_from_dict( + resp = kubernetes.utils.create_from_dict( k8s_batch_api.api_client, job_dict, namespace=ENV.K8S_NAMESPACE, ) - LOGGER.info(api_response) + LOGGER.info(json.dumps(resp, indent=0)) # otherwise huge except Exception: # broad b/c re-raising LOGGER.error("request to make k8s job failed using:") LOGGER.error(json.dumps(job_dict, indent=4)) raise else: - return api_response + return resp @staticmethod def get_pods(