Skip to content

Commit

Permalink
rename log msg
Browse files Browse the repository at this point in the history
  • Loading branch information
JavokhirAbdullayev committed Nov 15, 2024
1 parent d701705 commit 148d7bd
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
1 change: 0 additions & 1 deletion NEWS.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit 148d7bd

Please sign in to comment.