diff --git a/NEWS.md b/NEWS.md
index ef816da01..b00d2f096 100644
--- a/NEWS.md
+++ b/NEWS.md
@@ -24,7 +24,6 @@
 * [MODSOURMAN-1241](https://folio-org.atlassian.net/browse/MODSOURMAN-1241) Add missing module permissions for PUT /change-manager/parsedRecords/{id}
 * [MODSOURMAN-1222](https://folio-org.atlassian.net/browse/MODSOURMAN-1222) Fix inconsistencies in permission namings
 * [MODSOURMAN-1244](https://folio-org.atlassian.net/browse/MODSOURMAN-1244) Update MARC bib-instance default mapping to include additional subject types
-* [MODSOURMAN-1246](https://folio-org.atlassian.net/browse/MODSOURMAN-1246) Data import completion notifications
 * [MODSOURMAN-1240](https://folio-org.atlassian.net/browse/MODSOURMAN-1240) The title of record is not displayed on the JSON data after importing file for creating order
 
 ## 2023-03-22 v3.8.0
diff --git a/mod-source-record-manager-server/src/main/java/org/folio/verticle/JobExecutionProgressVerticle.java b/mod-source-record-manager-server/src/main/java/org/folio/verticle/JobExecutionProgressVerticle.java
index d41fcd10c..fed0925d0 100644
--- a/mod-source-record-manager-server/src/main/java/org/folio/verticle/JobExecutionProgressVerticle.java
+++ b/mod-source-record-manager-server/src/main/java/org/folio/verticle/JobExecutionProgressVerticle.java
@@ -279,8 +279,8 @@ private void sendDiJobCompletedEvent(JobExecution jobExecution, OkapiConnectionP
     kafkaHeaders.add(new KafkaHeaderImpl(USER_ID_HEADER, jobExecution.getUserId()));
     var key = String.valueOf(indexer.incrementAndGet() % MAX_DISTRIBUTION);
     sendEventToKafka(params.getTenantId(), Json.encode(jobExecution), DI_JOB_COMPLETED.value(), kafkaHeaders, kafkaConfig, key)
-      .onSuccess(event -> LOGGER.info("sendEventToBulkOps:: DI_JOB_COMPLETED event published, jobExecutionId={}", jobExecution.getId()))
-      .onFailure(event -> LOGGER.warn("sendEventToBulkOps:: Error publishing DI_JOB_COMPLETED event, jobExecutionId = {}", jobExecution.getId(), event));
+      .onSuccess(event -> LOGGER.info("sendDiJobCompletedEvent:: DI_JOB_COMPLETED event published, jobExecutionId={}", jobExecution.getId()))
+      .onFailure(event -> LOGGER.warn("sendDiJobCompletedEvent:: Error publishing DI_JOB_COMPLETED event, jobExecutionId = {}", jobExecution.getId(), event));
   }
 
   private Future<JobExecution> updateJobStatusToError(String jobExecutionId, OkapiConnectionParams params) {