Fix active-elastic-job#50 Pass region as argument to NonExistentQueue

rkiller · Jan 31, 2017 · e371313 · e371313
1 parent 7023166
commit e371313
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/active_job/queue_adapters/active_elastic_job_adapter.rb b/lib/active_job/queue_adapters/active_elastic_job_adapter.rb
@@ -142,7 +142,7 @@ def queue_url(queue_name)
           resp = aws_sqs_client.get_queue_url(queue_name: queue_name.to_s)
           @queue_urls[cache_key] = resp.queue_url
         rescue Aws::SQS::Errors::NonExistentQueue => e
-          raise NonExistentQueue, queue_name
+          raise NonExistentQueue.new(queue_name, aws_region)
         end
 
         def calculate_delay(timestamp)