in greengrass-v2/poll-api/artifacts/com.greengrass.CleanUpExportFiles/1.0.0/cleanup.py [0:0]
def inner_clean_up(message_list):
# Process the list of status messages
for message in message_list:
# Deserialize the status message first
status_message = Util.deserialize_json_bytes_to_obj(message.payload, StatusMessage)
file_url = status_message.status_context.s3_export_task_definition.input_url
filename = file_url.replace('file://', '')
if status_message.status == Status.Success:
GGUtils.logger.info(f"Successfully uploaded {filename} to S3.")
try:
os.remove(filename)
except OSError:
GGUtils.logger.error(f"Failed to delete {filename}.")
elif status_message.status == Status.Failure or status_message.status == Status.Canceled:
GGUtils.logger.error(f"Unable to upload {filename} to S3. Message: {status_message.message}")
GGUtils.logger.error(f"{filename} will NOT be deleted.")
else:
GGUtils.logger.info(f"Ignoring unknown status {filename}. Status: {status_message.status}")