fix(mod-search): fix export of cql files

- add new code Closes: MSEARCH-762
folio-org · Jun 7, 2024 · b5e3c63 · b5e3c63
1 parent 7317d08
commit b5e3c63
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/src/main/java/org/folio/search/service/ResourceIdsJobService.java b/src/main/java/org/folio/search/service/ResourceIdsJobService.java
@@ -42,9 +42,9 @@ public ResourceIdsJob createStreamJob(ResourceIdsJob job, String tenantId) {
     boolean isNotShared = !tenantId.equalsIgnoreCase("consortium")
       && entity.getQuery().contains("shared==\"false\"");
     var savedJob = isNotShared
-      ? saveAndRun(entity, tenantId)
+      ? consortiumTenantExecutor.executeSimple(() -> saveAndRun(entity, tenantId), tenantId)
       : consortiumTenantExecutor.execute(() -> saveAndRun(entity, tenantId));
-    log.info("[SLY] *** SIMPLE: {}, savedJob: {}", isNotShared, savedJob.toString());
+    log.info("[SLY] *** SIMPLE EXECUTED: {}, savedJob: {}", isNotShared, savedJob.toString());
 
     return resourceIdsJobMapper.convert(savedJob);
   }

diff --git a/src/main/java/org/folio/search/service/consortium/ConsortiumTenantExecutor.java b/src/main/java/org/folio/search/service/consortium/ConsortiumTenantExecutor.java
@@ -31,6 +31,11 @@ public <T> T execute(String originalTenantId, Supplier<T> operation) {
     }
   }
 
+  public <T> T executeSimple(Supplier<T> operation, String tenantId) {
+    log.info("[SLY] *** No changing context {}", tenantId);
+    return operation.get();
+  }
+
   public void run(Runnable operation) {
     execute(() -> {
       operation.run();