diff --git a/bignbit/save_cnm_message.py b/bignbit/save_cnm_message.py
index b486dc5..74b4c2b 100644
--- 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
index d299ce2..0021d5d 100644
--- 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
index 67ed688..6ed2eb1 100644
--- 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": "{$}"
             }
           }
         }