From 08b21897d2f7b70f4542aeb70b5ffeaa11482a1a Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Thu, 11 Feb 2021 18:53:35 +0100
Subject: [PATCH] TMSS-418: processed review comment. Postponing
synchronization to the LTA until a ProjectQuotaArchiveLocation is added to
the project
---
.../services/tmss_lta_adapter/lib/tmss_lta_adapter.py | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/SAS/TMSS/backend/services/tmss_lta_adapter/lib/tmss_lta_adapter.py b/SAS/TMSS/backend/services/tmss_lta_adapter/lib/tmss_lta_adapter.py
index 5dd7629547f..69e33f8fdf4 100644
--- a/SAS/TMSS/backend/services/tmss_lta_adapter/lib/tmss_lta_adapter.py
+++ b/SAS/TMSS/backend/services/tmss_lta_adapter/lib/tmss_lta_adapter.py
@@ -39,9 +39,7 @@ class TMSSEventMessageHandlerForLTASynchronization(TMSSEventMessageHandler):
self._lta_db = LTACatalogueDatabaseConnection(dbcredentials.DBCredentials().get(lta_creds_id))
def onProjectCreated(self, name: str):
- with self._tmss_client, self._lta_db:
- project = self._tmss_client.get_path_as_json_object('project/%s' % name)
- self._lta_db.create_project(project_name=project['name'], description=project['description'])
+ logger.info("Project '%s' was created in TMSS. Postponing synchronization to the LTA until a ProjectQuotaArchiveLocation is added to it...", name)
def onProjectUpdated(self, name: str):
logger.warning("TODO: implement synchronization to the LTA when a Project is updated")
@@ -57,6 +55,7 @@ class TMSSEventMessageHandlerForLTASynchronization(TMSSEventMessageHandler):
assert project_quota['resource_type_id'] == 'lta_storage'
+ self._lta_db.create_project(project_name=project['name'], description=project['description'])
self._lta_db.add_project_storage_resource(project_name=project['name'], nr_of_bytes=project_quota['value'], uri=project_quota_archive_location['full_archive_uri'])
def onProjectQuotaArchiveLocationUpdated(self, id: int):
--
GitLab