Обновление статуса повторной сертификации при рассмотрении заявки

public class SubscribeBMRecertEvent {
    // Implement the event handler method
    @InvocableMethod(label='Handle BMRecertEvent Platform Event')
    public static void handleEvent(List<BMRecertEvent__e> events) {
    for (BMRecertEvent__e event : events) {        
        List<IndividualApplication> recordsToUpdate = [SELECT Id, Status, ApplicationType, Category, BenefitAssignmentId FROM IndividualApplication WHERE Id = :event.RecordId__c];       
        for (IndividualApplication ia: recordsToUpdate) {
            BenefitAssignment baRecord = [SELECT Id, RecertificationStatus FROM BenefitAssignment WHERE Id = :ia.BenefitAssignmentId];
            baRecord.RecertificationStatus = 'InProgress';
            update baRecord;
        }
        }
    }
}

trigger BMRecertEventTrigger on BMRecertEvent__e (after insert) {
    SubscribeBMRecertEvent.handleEvent(Trigger.new);
}