diff --git a/scheduler/scheduler/tasks.py b/scheduler/scheduler/tasks.py index 19dc8083c56c3a6d41a3545c4ec031df1b12330a..9a3e1d0f2336a0388627ea0c827183d3dbb5e825 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")