fix comment

folio-org · Nov 14, 2024 · d2d4d1e · d2d4d1e
1 parent 726de0e
commit d2d4d1e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...-record-manager-server/src/main/java/org/folio/verticle/JobExecutionProgressVerticle.java b/...-record-manager-server/src/main/java/org/folio/verticle/JobExecutionProgressVerticle.java
@@ -256,7 +256,7 @@ private Future<Boolean> updateJobExecutionIfAllRecordsProcessed(String jobExecut
                             parentExecution.withStatus(JobExecution.Status.COMMITTED)
                               .withUiStatus(JobExecution.UiStatus.RUNNING_COMPLETE)
                               .withCompletedDate(new Date());
-                            sendEventToBulkOps(parentExecution, params);
+                            sendDiJobCompletedEvent(parentExecution, params);
                             return jobExecutionService.updateJobExecutionWithSnapshotStatus(parentExecution, params);
                           }
                           return Future.succeededFuture(parentExecution);
@@ -273,7 +273,7 @@ private Future<Boolean> updateJobExecutionIfAllRecordsProcessed(String jobExecut
     return Future.succeededFuture(false);
   }
 
-  private void sendEventToBulkOps(JobExecution jobExecution, OkapiConnectionParams params) {
+  private void sendDiJobCompletedEvent(JobExecution jobExecution, OkapiConnectionParams params) {
     var kafkaHeaders = KafkaHeaderUtils.kafkaHeadersFromMultiMap(params.getHeaders());
     kafkaHeaders.add(new KafkaHeaderImpl(JOB_EXECUTION_ID_HEADER, jobExecution.getId()));
     kafkaHeaders.add(new KafkaHeaderImpl(USER_ID_HEADER, jobExecution.getUserId()));