def handle_aws_backup_event()

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}")