From 900b7df8c106e91c0af1656789944e157aa8361c Mon Sep 17 00:00:00 2001
From: Ken Collins <ken@metaskills.net>
Date: Mon, 4 Oct 2021 19:32:51 -0400
Subject: [PATCH] Ensure `active_job` events are safe for non-Lambdakiq jobs.

---
 CHANGELOG.md             | 9 +++++++--
 Gemfile.lock             | 2 +-
 lib/lambdakiq/metrics.rb | 5 +++++
 lib/lambdakiq/version.rb | 2 +-
 lib/lambdakiq/worker.rb  | 4 ++++
 5 files changed, 18 insertions(+), 4 deletions(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index f029458..74691b7 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,10 +1,15 @@
-
 # Keep A Changelog!
 
 See this http://keepachangelog.com link for information on how we want this documented formatted.
 
+## v1.0.2
+
+#### Fixed
+
+- Ensure `active_job` events are safe for non-Lambdakiq jobs.
+
 ## v1.0.0
 
 #### Added
 
-* Initial release.
+- Initial release.
diff --git a/Gemfile.lock b/Gemfile.lock
index 05feb56..c73370a 100644
--- a/Gemfile.lock
+++ b/Gemfile.lock
@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    lambdakiq (1.0.1)
+    lambdakiq (1.0.2)
       activejob
       aws-sdk-sqs
       concurrent-ruby
diff --git a/lib/lambdakiq/metrics.rb b/lib/lambdakiq/metrics.rb
index 9d1c8aa..555fc44 100644
--- a/lib/lambdakiq/metrics.rb
+++ b/lib/lambdakiq/metrics.rb
@@ -16,6 +16,7 @@ def initialize(event)
     end
 
     def log
+      return unless lambdakiq?
       logger.info JSON.dump(message)
     end
 
@@ -29,6 +30,10 @@ def job_name
       job.class.name
     end
 
+    def lambdakiq?
+      job.respond_to?(:lambdakiq?) && job.lambdakiq?
+    end
+
     def logger
       Lambdakiq.config.metrics_logger
     end
diff --git a/lib/lambdakiq/version.rb b/lib/lambdakiq/version.rb
index 940821d..0d61f06 100644
--- a/lib/lambdakiq/version.rb
+++ b/lib/lambdakiq/version.rb
@@ -1,3 +1,3 @@
 module Lambdakiq
-  VERSION = '1.0.1'
+  VERSION = '1.0.2'
 end
diff --git a/lib/lambdakiq/worker.rb b/lib/lambdakiq/worker.rb
index 5f3f739..8ce0d28 100644
--- a/lib/lambdakiq/worker.rb
+++ b/lib/lambdakiq/worker.rb
@@ -16,6 +16,10 @@ def lambdakiq_options(options = {})
 
     end
 
+    def lambdakiq?
+      true
+    end
+
     def lambdakiq_retry
       lambdakiq_options_hash[:retry]
     end