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 5dd7629547fcaab58a7f14132e8fb779504fbcdb..69e33f8fdf42ffd22c4f6ed61c502d2e0ecfc529 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):