From bec0a4d8b77c8f9d55ea01e3fb64ec16ee3fe4e4 Mon Sep 17 00:00:00 2001
From: Daniel Orner <daniel.orner@flipp.com>
Date: Tue, 10 Dec 2024 15:15:39 -0500
Subject: [PATCH] fix tagged logging

---
 lib/deimos/logging.rb | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/lib/deimos/logging.rb b/lib/deimos/logging.rb
index f492f3b..a8f7083 100644
--- 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