Merge 213292d into fce033b

Author: wphyojpl

cumulus_lambda_functions/daac_archiver/daac_archiver_logic.py

@@ -117,7 +117,7 @@ def send_to_daac_internal(self, uds_cnm_json: dict):
                 },
                 "identifier": uds_cnm_json['identifier'],
                 "submissionTime": f'{TimeUtils.get_current_time()}Z',
-                "provider": granule_identifier.tenant,
+                "provider": daac_config['daac_provider'],
                 "version": "1.6.0",  # TODO this is hardcoded?
                 "product": {
                     "name": granule_identifier.granule,

cumulus_lambda_functions/granules_to_es/granules_index_mapping.py

@@ -9,6 +9,9 @@ class GranulesIndexMapping:
         "daac_data_version": {
             "type": "keyword"
         },
+        "daac_provider": {
+            "type": "keyword"
+        },
         "daac_role_arn": {
             "type": "keyword"
         },

cumulus_lambda_functions/lib/uds_db/archive_index.py

@@ -15,10 +15,11 @@ class UdsArchiveConfigIndex:
     basic_schema = {
         'type': 'object',
         "additionalProperties": False,
-        'required': ['daac_collection_id', 'daac_sns_topic_arn', 'daac_data_version', 'daac_role_arn', 'daac_role_session_name',
+        'required': ['daac_collection_id', 'daac_sns_topic_arn', 'daac_provider', 'daac_data_version', 'daac_role_arn', 'daac_role_session_name',
                      'collection', 'ss_username', 'archiving_types'],
         'properties': {
             'daac_collection_id': {'type': 'string'},
+            'daac_provider': {'type': 'string'},
             'daac_sns_topic_arn': {'type': 'string'},
             'daac_data_version': {'type': 'string'},
             'daac_role_arn': {'type': 'string'},
@@ -31,11 +32,12 @@ class UdsArchiveConfigIndex:
 
     db_record_schema = {
         'type': 'object',
-        'required': ['daac_collection_name', 'daac_sns_topic_arn', 'daac_data_version', 'daac_role_arn',
+        'required': ['daac_collection_name', 'daac_sns_topic_arn', 'daac_provider', 'daac_data_version', 'daac_role_arn',
                      'daac_role_session_name',
                      'collection', 'ss_username', 'archiving_types'],
         'properties': {
             'daac_collection_name': {'type': 'string'},
+            'daac_provider': {'type': 'string'},
             'daac_sns_topic_arn': {'type': 'string'},
             'daac_data_version': {'type': 'string'},
             'daac_role_arn': {'type': 'string'},

cumulus_lambda_functions/uds_api/dapa/daac_archive_crud.py

@@ -17,6 +17,7 @@ class ArchivingTypesModel(BaseModel):
 
 class DaacUpdateModel(BaseModel):
     daac_collection_id: str
+    daac_provider: Optional[str] = None
     daac_data_version: Optional[str] = None
     daac_sns_topic_arn: Optional[str] = None
     daac_role_arn: Optional[str] = None
@@ -26,6 +27,7 @@ class DaacUpdateModel(BaseModel):
 
 class DaacAddModel(BaseModel):
     daac_collection_id: str
+    daac_provider: str
     daac_data_version: str
     daac_sns_topic_arn: str
     daac_role_arn: str