Skip to content

Commit 22d8c53

Browse files
committed
chore(scheduler): change log level to DEBUG for cached state store
1 parent c7877d0 commit 22d8c53

2 files changed

Lines changed: 6 additions & 6 deletions

File tree

scheduler/src/main/java/io/kestra/scheduler/stores/CachedFlowMetaStore.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ public void init(final Set<Integer> vNodes) {
147147

148148
private void loadCacheForAllVNodes(final Set<Integer> vNodes) {
149149
long start = System.currentTimeMillis();
150-
LOG.info("Loading flows for vNodes {}", vNodes);
150+
LOG.debug("Loading flows for vNodes {}", vNodes);
151151
// Create or warm up caches for new vNodes
152152
AtomicInteger count = new AtomicInteger(0);
153153
for (Integer vnode : vNodes) {
@@ -162,11 +162,11 @@ private void loadCacheForAllVNodes(final Set<Integer> vNodes) {
162162
return cache;
163163
});
164164
}
165-
LOG.info("{} flows loaded for vNodes {} in {}ms", count, vNodes, System.currentTimeMillis() - start);
165+
LOG.debug("{} flows loaded for vNodes {} in {}ms", count, vNodes, System.currentTimeMillis() - start);
166166
}
167167

168168
public void clear() {
169-
LOG.info("Clearing local cache");
169+
LOG.debug("Clearing local cache");
170170
partitionedCache.values().forEach(Cache::invalidateAll);
171171
partitionedCache.clear();
172172
}

scheduler/src/main/java/io/kestra/scheduler/stores/CachedTriggerStateStore.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ public void init(final Set<Integer> vNodes) {
156156

157157
private void loadCacheForAllVNodes(final Set<Integer> vNodes) {
158158
long start = System.currentTimeMillis();
159-
LOG.info("Loading trigger states for vnodes {}", vNodes);
159+
LOG.debug("Loading trigger states for vnodes {}", vNodes);
160160
// Create or warm up caches for new vNodes
161161
AtomicInteger count = new AtomicInteger(0);
162162
for (Integer vnode : vNodes) {
@@ -171,11 +171,11 @@ private void loadCacheForAllVNodes(final Set<Integer> vNodes) {
171171
return cache;
172172
});
173173
}
174-
LOG.info("Loaded {} trigger states for vnoded {} in {}ms", count, vNodes, System.currentTimeMillis() - start);
174+
LOG.debug("Loaded {} trigger states for vnoded {} in {}ms", count, vNodes, System.currentTimeMillis() - start);
175175
}
176176

177177
public void clear() {
178-
LOG.info("Clearing all trigger state caches (no assigned vNodes)");
178+
LOG.debug("Clearing all trigger state caches (no assigned vNodes)");
179179
partitionedCache.values().forEach(Cache::invalidateAll);
180180
partitionedCache.clear();
181181
}

0 commit comments

Comments
 (0)