add prefix to cnm path and fix gitc response

podaac · Jun 4, 2024 · 9fb5af6 · 9fb5af6
1 parent 04be710
commit 9fb5af6
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/bignbit/handle_gitc_response.py b/bignbit/handle_gitc_response.py
@@ -40,7 +40,7 @@ def handler(event, _):
         umm_json = utils.get_umm_json(granule_concept_id, cmr_env)
         granule_ur = umm_json['GranuleUR']
 
-        cnm_key_name = collection_name + "/" + granule_ur + "." + message_body['submission_time'] + "." + "cnm-r.json"
+        cnm_key_name = os.environ['POBIT_AUDIT_PATH_NAME'] + "/" + collection_name + "/" + granule_ur + "." + message_body['submissionTime'] + "." + "cnm-r.json"
 
         utils.upload_cnm(os.environ['POBIT_AUDIT_BUCKET_NAME'], cnm_key_name, json.dumps(message_body))
 

diff --git a/bignbit/save_cnm_message.py b/bignbit/save_cnm_message.py
@@ -30,13 +30,14 @@ def process(self):
 
         """
         pobit_audit_bucket = self.config['pobit_audit_bucket']
+        pobit_audit_path = self.config['pobit_audit_path']
 
         collection_name = self.config['collection']
         granule_ur = self.config['granule_ur']
 
         cnm_content = self.config['cnm']
 
-        cnm_key_name = collection_name + "/" + granule_ur + "." + cnm_content['submissionTime'] + "." + "cnm.json"
+        cnm_key_name = pobit_audit_path + "/" + collection_name + "/" + granule_ur + "." + cnm_content['submissionTime'] + "." + "cnm.json"
 
         upload_cnm(pobit_audit_bucket, cnm_key_name, cnm_content)
 

diff --git a/terraform/state_machine_definition.tpl b/terraform/state_machine_definition.tpl
@@ -462,6 +462,7 @@
                   "granule_ur": "{$.granule_ur}",
                   "cnm": "{$.cnm.Payload.payload}",
                   "pobit_audit_bucket": "${PobitAuditBucket}",
+                  "pobit_audit_path": "${PobitAuditPath}",
                   "cumulus_message": {
                     "input": "{$}"
                   }