We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1f28c26 commit fe7ca1bCopy full SHA for fe7ca1b
cumulus_lambda_functions/granules_to_es/granules_indexer.py
@@ -78,8 +78,12 @@ def start(self):
78
return
79
self.__cumulus_record = incoming_msg['record']
80
if len(self.__cumulus_record['files']) < 1:
81
+ LOGGER.debug(f'No files in cumulus record. Not inserting to ES')
82
# TODO ingest updating stage?
83
84
+ if 'status' not in self.__cumulus_record or self.__cumulus_record['status'].upper() != 'COMPLETED':
85
+ LOGGER.debug(f'missing status or it is NOT COMPLETED status. Not inserting to ES')
86
+ return
87
stac_input_meta = None
88
potential_files = self.__get_potential_files()
89
LOGGER.debug(f'potential_files: {potential_files}')
0 commit comments