From 44dad11478b235ac3669af575119e828b3245aeb Mon Sep 17 00:00:00 2001
From: Max Lou Hartel-Kaduk <mhartel@digitallearning.gmbh>
Date: Mon, 13 Feb 2023 12:59:21 +0100
Subject: [PATCH] Fix: handle results retention failure
---
scheduler/scheduler/tasks.py | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/scheduler/scheduler/tasks.py b/scheduler/scheduler/tasks.py
index 19dc808..9a3e1d0 100644
--- a/scheduler/scheduler/tasks.py
+++ b/scheduler/scheduler/tasks.py
@@ -16,7 +16,6 @@ RIGHTS_ENGINE_BACKEND = settings.get("RIGHTS_ENGINE_BACKEND_URL", "")
def append_job_log(result_token, job_id, job_output, succeeded=True):
url = f"{ANALYTICS_BACKEND}/api/v1/jobs/{job_id}/log"
- print(url)
response = requests.post(
url,
json={"result_token": result_token, "log": job_output, "succeeded": succeeded},
@@ -28,10 +27,14 @@ def append_job_log(result_token, job_id, job_output, succeeded=True):
def run_results_retention(analytics_token):
url = f"{RIGHTS_ENGINE_BACKEND}/api/v1/provider/results-retention"
- response = requests.post(url, headers={"Authorization": f"Basic {analytics_token}"})
- if not response.ok:
- print(response.status_code)
- print("Failed execute results retention")
+ print(url)
+ try:
+ response = requests.post(url, headers={"Authorization": f"Basic {analytics_token}"})
+ if not response.ok:
+ print(response.status_code)
+ print("Failed execute results retention")
+ except Exception as e:
+ print(e)
@shared_task(name="celery_tasks.run_analysis")
--
GitLab