bugfix for logging level

oicr-gsi · Jul 8, 2024 · 4f471f3 · 4f471f3
1 parent 9272485
commit 4f471f3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/plugin-loki/src/main/java/ca/on/oicr/gsi/shesmu/loki/LokiPlugin.java b/plugin-loki/src/main/java/ca/on/oicr/gsi/shesmu/loki/LokiPlugin.java
@@ -165,7 +165,8 @@ protected synchronized Optional<Integer> update(Configuration configuration) {
   public synchronized void writeLog(
       String message, LogLevel level, Map<String, String> attributes) {
     final var now = Instant.now();
-    buffer.computeIfAbsent(attributes, k -> new ArrayList<>()).add(new Pair<>(now, message));
-    if (level.compareTo(this.configuration.get().getLevel()) >= 0) flush(now);
+    if (level.compareTo(this.configuration.get().getLevel()) >= 0)
+      buffer.computeIfAbsent(attributes, k -> new ArrayList<>()).add(new Pair<>(now, message));
+    flush(now);
   }
 }