Set Up Process End Notification for Bulk Renewals

Learn how to use the platform event from the batch framework to detect when a bulk policy renewal job completes and trigger a notification or follow-up action. Use the platform event triggered by the batch framework at the end of a batch job. A Platform Event–Triggered flow subscribes to all Batch Job Status Change Events from the batch framework.

1. Create a Platform Event–Triggered flow.
2. Select the Batch Job Status Changed Event platform event.
3. Filter events based on batch job definition and status.
4. Add an Apex action to the Flow. The action enqueues a queueable apex job that checks the bulk renew request status based on data in monitoring entities.

   Sample Apex Class: CallRenewStatusQueueable

   public with sharing class CallRenewStatusQueueable {
     @InvocableMethod
     public static void execute(List<Requests> requestList) {
       for (Requests request : requestList) {
         String jobId = request.batchJobId;
         BatchJob job = [SELECT RuntimeParameter FROM BatchJob WHERE Id = :jobId];
         Map<String, Object> paramsMap = 
           (Map<String, Object>) JSON.deserializeUntyped(job.RuntimeParameter);
   
         List<Object> inputParams = 
           (List<Object>) paramsMap.get('batchJobFlowRunTimeParameters');
   
         String jobIdentifier = '';
         for (Object param : inputParams) {
           Map<String, Object> temp = (Map<String, Object>) param;
           if (temp.get('name') == 'requestId [Flow]') {
             jobIdentifier = (String) temp.get('value');
           }
         }
   
         System.enqueueJob(new CheckBulkRenewStatus(jobIdentifier), 10);
       }
     }
   
     public class Requests {
       @InvocableVariable(required=true)
       public String batchJobId;
     }
   }
   

5. Define the Queueable Apex Job.
   Sample Class: CheckBulkRenewStatus

   public class CheckBulkRenewStatus implements Queueable {
     private String jobIdentifier;
   
     public CheckBulkRenewStatus(String jobIdentifier) {
       this.jobIdentifier = jobIdentifier;
     }
   
     public void execute(QueueableContext context) {
       InsuranceAsyncBulkRequest asyncRequest = [
         SELECT Id FROM InsuranceAsyncBulkRequest 
         WHERE JobIdentifier = :jobIdentifier LIMIT 1
       ];
   
       InsuranceAsyncBulkRequestItem item = [
         SELECT Id FROM InsuranceAsyncBulkRequestItem 
         WHERE InsuranceAsyncBulkRequestId = :asyncRequest.Id
       ];
   
       List<InsuranceAsyncBulkRecordDetail> pendingItems = [
         SELECT Id FROM InsuranceAsyncBulkRecordDetail 
         WHERE InsuranceAsyncBulkRequestItemId = :item.Id 
         AND Status IN ('In Progress', 'Scheduled')
       ];
   
       if (pendingItems.size() > 0) {
         System.enqueueJob(new CheckBulkRenewStatus(jobIdentifier), 10); // Retry
       } else {
         // All renewals completed — raise an event or notify user
         System.debug('Bulk renewal complete. Sending final notification.');
       }
     }
   }
   

6. Save your changes, and activate the flow.