also increment counter

airbnb · Jan 31, 2024 · 4e7b687 · 4e7b687
1 parent d7decc9
commit 4e7b687
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/online/src/main/scala/ai/chronon/online/Fetcher.scala b/online/src/main/scala/ai/chronon/online/Fetcher.scala
@@ -292,7 +292,10 @@ class Fetcher(val kvStore: KVStore,
         )
         if (logFunc != null) {
           val sentLog = Try(logFunc.accept(loggableResponse))
-          if (sentLog.isFailure) logger.error("Failed to publish log", sentLog.failed.get)
+          if (sentLog.isFailure) {
+            logger.error("Failed to publish log", sentLog.failed.get)
+            joinContext.foreach(context => context.increment("logging_failure.count"))
+          }
           joinContext.foreach(context => context.increment("logging_request.count"))
           joinContext.foreach(context =>
             context.distribution("logging_request.latency.millis", System.currentTimeMillis() - loggingStartTs))