in Lambda/TagOnRestore/src/TagOnRestore.py [0:0]
def handle_aws_backup_event(self, event):
detail_type = event.get('detail-type')
event_detail = event.get('detail')
job_event_state = event_detail.get('state')
if not job_event_state:
# Hack
job_event_state = event_detail.get('status')
if job_event_state in ('ABORTED', 'COMPLETED', 'FAILED', 'EXPIRED'):
if detail_type == 'Restore Job State Change':
job_event_type = 'restore_job'
job_id = event_detail.get('restoreJobId')
if job_event_state in ('COMPLETED'):
self.handle_restore_event_data(job_id)
else:
logger.error(f"Skipping processing for type : {detail_type} for aws.backup")
return
logger.info(
f"Processed Event Type : {job_event_type} , Event State : {job_event_state}, Job Id : {job_id}")
else:
logger.info(f"Ignore processing job with a status : {job_event_state}")