From 5330354b80f9cee9ee88bd5b78bfaedb6fe281b9 Mon Sep 17 00:00:00 2001
From: Mario Raciti <mario.raciti@inaf.it>
Date: Thu, 1 Apr 2021 16:43:37 +0200
Subject: [PATCH] TMSS-692: Add first step to get dataproducts' sizes
---
SAS/TMSS/backend/src/tmss/tmssapp/adapters/reports.py | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git a/SAS/TMSS/backend/src/tmss/tmssapp/adapters/reports.py b/SAS/TMSS/backend/src/tmss/tmssapp/adapters/reports.py
index 58f7584329e..1f86d2fa7b5 100644
--- a/SAS/TMSS/backend/src/tmss/tmssapp/adapters/reports.py
+++ b/SAS/TMSS/backend/src/tmss/tmssapp/adapters/reports.py
@@ -36,6 +36,9 @@ def _get_subs_and_durations_from_project(project_pk: int) -> {}:
def create_project_report(request: Request, project: models.Project) -> {}:
+ """
+ Create a project report as a JSON object.
+ """
# TODO: Retrieve the information needed, all in one go.
project_pk = project.pk
result = {'project': project_pk} # Object to be returned
@@ -48,4 +51,12 @@ def create_project_report(request: Request, project: models.Project) -> {}:
# Add durations to result
result['durations'] = _get_subs_and_durations_from_project(project_pk)
+ # Subtask of type 'ingest' within 'finished' status
+ subtasks = models.Subtask.objects.filter(specifications_template__type='ingest', state='finished')
+ for subtask in subtasks:
+ # TODO: Get sum of dataproduct sizes that went to the ingest
+ output_dataproducts = models.SubtaskOutput.filter(subtask=subtask.pk)
+
+ # TODO: For each unique target (SAP name) get the sum of target observation durations from the tasks.
+
return result
--
GitLab