Reduce info logs (#1087)

spotify · Jun 27, 2023 · e355ca8 · e355ca8
1 parent f9664ab
commit e355ca8
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/styx-scheduler-service/src/main/java/com/spotify/styx/docker/KubernetesDockerRunner.java b/styx-scheduler-service/src/main/java/com/spotify/styx/docker/KubernetesDockerRunner.java
@@ -684,7 +684,7 @@ private void logEvent(Watcher.Action action, Pod pod, String resourceVersion,
         .orElse("N/A");
     final String status = readStatus(pod);
 
-    LOG.info("{}Pod event for {} ({}) at resource version {}, action: {}, workflow instance: {}, status: {}",
+    LOG.debug("{}Pod event for {} ({}) at resource version {}, action: {}, workflow instance: {}, status: {}",
              polled ? "Polled: " : "", podName, pod.getMetadata().getUid(), resourceVersion, action, workflowInstance,
              status);
   }

diff --git a/styx-scheduler-service/src/main/java/com/spotify/styx/state/PersistentStateManager.java b/styx-scheduler-service/src/main/java/com/spotify/styx/state/PersistentStateManager.java
@@ -137,7 +137,7 @@ private void tickInstance(WorkflowInstance instance) {
   }
 
   private void tickInstance(RunState state) {
-    log.info("Ticking instance: {}: #{} {}", state.workflowInstance(), state.counter(), state.state());
+    log.debug("Ticking instance: {}: #{} {}", state.workflowInstance(), state.counter(), state.state());
     try {
       outputHandler.transitionInto(state, this);
     } catch (StateTransitionConflictException e) {

diff --git a/styx-service-common/src/main/java/com/spotify/styx/util/ShardedCounter.java b/styx-service-common/src/main/java/com/spotify/styx/util/ShardedCounter.java
@@ -292,7 +292,7 @@ void updateCounterShard(StorageTransaction transaction, String counterId, long d
         throw new CounterCapacityException(message);
       }
       final String operation = delta > 0 ? "increment" : "decrement";
-      LOG.info("Updating counter shard ({}): {}-{}: capacity={}, value={}, delta={}, newValue={}",
+      LOG.debug("Updating counter shard ({}): {}-{}: capacity={}, value={}, delta={}, newValue={}",
           operation, counterId, shardIndex, shardCapacity, shard.get().value(), delta, newShardValue);
     } else {
       final String message =