fix tagged logging

flipp-oss · Dec 10, 2024 · bec0a4d · bec0a4d
1 parent 1721ea8
commit bec0a4d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/deimos/logging.rb b/lib/deimos/logging.rb
@@ -3,7 +3,11 @@ module Logging
     class << self
 
       def log_add(method, msg)
-        Karafka.logger.tagged('Deimos') do |logger|
+        if Karafka.logger.respond_to?(:tagged)
+          Karafka.logger.tagged('Deimos') do |logger|
+            logger.send(method, msg.to_json)
+          end
+        else
           logger.send(method, msg.to_json)
         end