From c83439521fffb490985de91d6b6445f720b089ee Mon Sep 17 00:00:00 2001
From: Maxim-Gadalov <gmaksim2012@gmail.com>
Date: Mon, 4 Mar 2024 16:03:38 +0100
Subject: [PATCH] add more logs

---
 .../java/com/epam/aidial/core/service/ResourceService.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/main/java/com/epam/aidial/core/service/ResourceService.java b/src/main/java/com/epam/aidial/core/service/ResourceService.java
index adb5f7145..232fabddb 100644
--- a/src/main/java/com/epam/aidial/core/service/ResourceService.java
+++ b/src/main/java/com/epam/aidial/core/service/ResourceService.java
@@ -282,6 +282,7 @@ private Void sync() {
             long now = time();
 
             for (String redisKey : set.valueRange(Double.NEGATIVE_INFINITY, true, now, true, 0, syncBatch)) {
+                log.info("Redis key from queue {}", redisKey);
                 sync(redisKey);
             }
         } catch (Throwable e) {
@@ -431,6 +432,7 @@ private void redisPut(String key, Result result) {
         map.putAll(fields);
 
         if (result.synced) { // cleanup because it is already synced
+            log.info("RedisPut key removed from queue {}", key);
             map.expire(cacheExpiration);
             set.remove(key);
         }
@@ -442,6 +444,7 @@ private void redisSync(String key) {
         map.expire(cacheExpiration);
 
         RScoredSortedSet<String> set = redis.getScoredSortedSet(REDIS_QUEUE, StringCodec.INSTANCE);
+        log.info("RedisSync key removed from queue {}", key);
         set.remove(key);
     }