Skip to content

Commit 57fe6ed

Browse files
committed
Release 1.0.4
1 parent d1c63ea commit 57fe6ed

File tree

4 files changed

+12
-7
lines changed

4 files changed

+12
-7
lines changed

CHANGELOG.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,11 @@
22

33
See this http://keepachangelog.com link for information on how we want this documented formatted.
44

5-
## v1.0.2, v1.0.3
5+
## v1.0.2, v1.0.3, v1.0.4
66

77
#### Fixed
88

9-
- Ensure `active_job` events are safe for non-Lambdakiq jobs.
9+
- Rails v5.2 compatibility. Metrics logging is are safe for non-Lambdakiq jobs
1010

1111
## v1.0.0
1212

Gemfile.lock

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
PATH
22
remote: .
33
specs:
4-
lambdakiq (1.0.3)
4+
lambdakiq (1.0.4)
55
activejob
66
aws-sdk-sqs
77
concurrent-ruby

lib/lambdakiq/metrics.rb

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,14 @@ def job_name
3030
job.class.name
3131
end
3232

33+
def adapter_name
34+
event.payload[:adapter].class.name
35+
end
36+
3337
def lambdakiq?
34-
job.respond_to?(:lambdakiq?) && job.lambdakiq?
38+
adapter_name.include?('Lambdakiq') &&
39+
job.respond_to?(:lambdakiq?) &&
40+
job.lambdakiq?
3541
end
3642

3743
def logger
@@ -65,7 +71,7 @@ def instrument!
6571
set_property 'QueueName', job.queue_name
6672
set_property 'MessageId', job.provider_job_id if job.provider_job_id
6773
set_property 'ExceptionName', exception_name if exception_name
68-
set_property 'EnqueuedAt', job.enqueued_at if job.enqueued_at
74+
set_property 'EnqueuedAt', job.enqueued_at if job.respond_to?(:enqueued_at) && job.enqueued_at
6975
set_property 'Executions', job.executions if job.executions
7076
job.arguments.each_with_index do |argument, index|
7177
set_property "JobArg#{index+1}", argument
@@ -113,4 +119,3 @@ def rails_app_name
113119

114120
end
115121
end
116-

lib/lambdakiq/version.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
module Lambdakiq
2-
VERSION = '1.0.3'
2+
VERSION = '1.0.4'
33
end

0 commit comments

Comments
 (0)