Skip to content
Snippets Groups Projects
Commit 44dad114 authored by Max Lou's avatar Max Lou
Browse files

Fix: handle results retention failure

parent ea3dbc24
No related branches found
No related tags found
No related merge requests found
...@@ -16,7 +16,6 @@ RIGHTS_ENGINE_BACKEND = settings.get("RIGHTS_ENGINE_BACKEND_URL", "") ...@@ -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): def append_job_log(result_token, job_id, job_output, succeeded=True):
url = f"{ANALYTICS_BACKEND}/api/v1/jobs/{job_id}/log" url = f"{ANALYTICS_BACKEND}/api/v1/jobs/{job_id}/log"
print(url)
response = requests.post( response = requests.post(
url, url,
json={"result_token": result_token, "log": job_output, "succeeded": succeeded}, 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): ...@@ -28,10 +27,14 @@ def append_job_log(result_token, job_id, job_output, succeeded=True):
def run_results_retention(analytics_token): def run_results_retention(analytics_token):
url = f"{RIGHTS_ENGINE_BACKEND}/api/v1/provider/results-retention" url = f"{RIGHTS_ENGINE_BACKEND}/api/v1/provider/results-retention"
print(url)
try:
response = requests.post(url, headers={"Authorization": f"Basic {analytics_token}"}) response = requests.post(url, headers={"Authorization": f"Basic {analytics_token}"})
if not response.ok: if not response.ok:
print(response.status_code) print(response.status_code)
print("Failed execute results retention") print("Failed execute results retention")
except Exception as e:
print(e)
@shared_task(name="celery_tasks.run_analysis") @shared_task(name="celery_tasks.run_analysis")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment