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 set = redis.getScoredSortedSet(REDIS_QUEUE, StringCodec.INSTANCE); + log.info("RedisSync key removed from queue {}", key); set.remove(key); }