Skip to content

Commit

Permalink
fix(mod-search): fix export of cql files
Browse files Browse the repository at this point in the history
- Add logging

Closes: MSEARCH-762
  • Loading branch information
viacheslavpoliakov committed Jun 11, 2024
1 parent d36f195 commit 3060122
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -145,6 +145,7 @@ private void streamResourceIds(CqlResourceIdsRequest request, Consumer<List<Stri
.fetchSource(new String[] {request.getSourceFieldPath()}, null)
.sort(fieldSort("_doc"));

log.info("[streamResourceIds] QUERY TO ELASTIC: {}", request.getQuery());
searchRepository.streamResourceIds(request, searchSource, idsConsumer);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ public ResourceIdsJob createStreamJob(ResourceIdsJob job, String tenantId) {
entity.setTemporaryTableName(generateTemporaryTableName());

log.info("Attempts to create streamJob by [resourceIdsJob: {}]", entity);
log.info("[createStreamJob] QUERY: {}", job.getQuery());
var savedJob = consortiumTenantExecutor.execute(() -> saveAndRun(entity, tenantId));

return resourceIdsJobMapper.convert(savedJob);
Expand Down

0 comments on commit 3060122

Please sign in to comment.