debugging

podaac · May 29, 2024 · eaddd63 · eaddd63
1 parent b02dd73
commit eaddd63
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/bignbit/save_cnm_message.py b/bignbit/save_cnm_message.py
@@ -34,11 +34,12 @@ def process(self):
         collection_name = self.config['collection']
         granule_ur = self.config['granule_ur']
 
-        cnm_content = self.input
+        cnm_content = self.input['cnm']
 
-        CUMULUS_LOGGER.info(collection_name)
-        CUMULUS_LOGGER.info(granule_ur)
-        CUMULUS_LOGGER.info(cnm_content['submissionTime'])
+        print(collection_name)
+        print(granule_ur)
+        print(cnm_content)
+        print(cnm_content['submissionTime'])
         cnm_key_name = collection_name + "/" + granule_ur + "." + cnm_content['submissionTime'] + "." + "cnm.json"
 
         upload_cnm(pobit_audit_bucket, cnm_key_name, cnm_content)

diff --git a/bignbit/send_to_gitc.py b/bignbit/send_to_gitc.py
@@ -53,10 +53,9 @@ def process(self):
 
             response_payload = {}
             response_payload = self.input.copy()
-            response_payload['cnm'] = []
 
             cnm_message = notify_gitc(image_set, cmr_provider, gitc_id, collection_name)
-            response_payload['cnm'].append(cnm_message)
+            response_payload['cnm'] = cnm_message
 
         return response_payload
 

diff --git a/terraform/state_machine_definition.tpl b/terraform/state_machine_definition.tpl
@@ -485,7 +485,7 @@
             "granule_ur": "{$.granule_ur}",
             "pobit_audit_bucket": "${PobitAuditBucket}",
             "cumulus_message": {
-              "input": "{$.payload.pobit.cnm}"
+              "input": "{$}"
             }
           }
         }