Skip to content

Commit 4571334

Browse files
committed
DEBUG: Can we change visibility without consumer errors?
1 parent 654ebfb commit 4571334

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

lib/lambdakiq/job.rb

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,9 @@ def handler(event)
1010
jobs = records.map { |record| new(record) }
1111
jobs.each(&:perform)
1212
jwerror = jobs.detect{ |j| j.error }
13-
return unless jwerror
14-
raise JobError.new(jwerror.error)
13+
return { statusCode: 422 }
14+
# return unless jwerror
15+
# raise JobError.new(jwerror.error)
1516
end
1617

1718
end
@@ -50,7 +51,7 @@ def perform
5051

5152
def execute
5253
ActiveJob::Base.execute(job_data)
53-
delete_message
54+
# delete_message
5455
rescue Exception => e
5556
increment_executions
5657
perform_error(e)

0 commit comments

Comments
 (0)