Skip to content

Commit d117486

Browse files
committed
chore: update log statements
1 parent fd33cb7 commit d117486

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

cumulus_lambda_functions/daac_archiver/daac_archiver_logic.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ def __extract_files(self, uds_cnm_json: dict, daac_config: dict):
7373
archiving_types = {k['data_type']: [] if 'file_extension' not in k else k['file_extension'] for k in daac_config['archiving_types']}
7474
result_files = []
7575
for each_file in granule_files:
76-
print(f'each_file: {each_file}')
76+
LOGGER.debug(f'each_file: {each_file}')
7777
"""
7878
{
7979
"type": "data",
@@ -97,6 +97,7 @@ def __extract_files(self, uds_cnm_json: dict, daac_config: dict):
9797
return result_files
9898

9999
def send_to_daac_internal(self, uds_cnm_json: dict):
100+
LOGGER.debug(f'uds_cnm_json: {uds_cnm_json}')
100101
granule_identifier = UdsCollections.decode_identifier(uds_cnm_json['identifier']) # This is normally meant to be for collection. Since our granule ID also has collection id prefix. we can use this.
101102
self.__archive_index_logic.set_tenant_venue(granule_identifier.tenant, granule_identifier.venue)
102103
daac_config = self.__archive_index_logic.percolate_document(uds_cnm_json['identifier'])
@@ -124,8 +125,7 @@ def send_to_daac_internal(self, uds_cnm_json: dict):
124125
'files': self.__extract_files(uds_cnm_json, daac_config),
125126
}
126127
}
127-
print(f'uds_cnm_json: {uds_cnm_json}')
128-
print(f'daac_cnm_message: {daac_cnm_message}')
128+
LOGGER.debug(f'daac_cnm_message: {daac_cnm_message}')
129129
self.__sns.set_external_role(daac_config['daac_role_arn'], daac_config['daac_role_session_name']).publish_message(json.dumps(daac_cnm_message), True)
130130
self.__granules_index.update_entry(granule_identifier.tenant, granule_identifier.venue, {
131131
'archive_status': 'cnm_s_success',

0 commit comments

Comments
 (0)