[Active Job] `rubocop -a --only Layout/EmptyLineAfterMagicComment`

activejob/Rakefile

 # frozen_string_literal: true
+
 require "rake/testtask"
 
 #TODO: add qu back to the list after it support Rails 5.1

activejob/activejob.gemspec

 # frozen_string_literal: true
+
 version = File.read(File.expand_path("../RAILS_VERSION", __dir__)).strip
 
 Gem::Specification.new do |s|

activejob/lib/active_job.rb

 # frozen_string_literal: true
+
 #--
 # Copyright (c) 2014-2017 David Heinemeier Hansson
 #

activejob/lib/active_job/arguments.rb

 # frozen_string_literal: true
+
 require "active_support/core_ext/hash"
 
 module ActiveJob

activejob/lib/active_job/base.rb

 # frozen_string_literal: true
+
 require_relative "core"
 require_relative "queue_adapter"
 require_relative "queue_name"

activejob/lib/active_job/callbacks.rb

 # frozen_string_literal: true
+
 require "active_support/callbacks"
 
 module ActiveJob

activejob/lib/active_job/configured_job.rb

 # frozen_string_literal: true
+
 module ActiveJob
   class ConfiguredJob #:nodoc:
     def initialize(job_class, options = {})

activejob/lib/active_job/core.rb

 # frozen_string_literal: true
+
 module ActiveJob
   # Provides general behavior that will be included into every Active Job
   # object that inherits from ActiveJob::Base.

activejob/lib/active_job/enqueuing.rb

 # frozen_string_literal: true
+
 require_relative "arguments"
 
 module ActiveJob

activejob/lib/active_job/exceptions.rb

 # frozen_string_literal: true
+
 require "active_support/core_ext/numeric/time"
 
 module ActiveJob

activejob/lib/active_job/execution.rb

 # frozen_string_literal: true
+
 require "active_support/rescuable"
 require_relative "arguments"
 

activejob/lib/active_job/gem_version.rb

 # frozen_string_literal: true
+
 module ActiveJob
   # Returns the version of the currently loaded Active Job as a <tt>Gem::Version</tt>
   def self.gem_version

activejob/lib/active_job/logging.rb

 # frozen_string_literal: true
+
 require "active_support/core_ext/hash/transform_values"
 require "active_support/core_ext/string/filters"
 require "active_support/tagged_logging"

activejob/lib/active_job/queue_adapter.rb

 # frozen_string_literal: true
+
 require "active_support/core_ext/string/inflections"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters.rb

 # frozen_string_literal: true
+
 module ActiveJob
   # == Active Job adapters
   #

activejob/lib/active_job/queue_adapters/async_adapter.rb

 # frozen_string_literal: true
+
 require "securerandom"
 require "concurrent/scheduled_task"
 require "concurrent/executor/thread_pool_executor"

activejob/lib/active_job/queue_adapters/backburner_adapter.rb

 # frozen_string_literal: true
+
 require "backburner"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb

 # frozen_string_literal: true
+
 require "delayed_job"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/inline_adapter.rb

 # frozen_string_literal: true
+
 module ActiveJob
   module QueueAdapters
     # == Active Job Inline adapter

activejob/lib/active_job/queue_adapters/qu_adapter.rb

 # frozen_string_literal: true
+
 require "qu"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/que_adapter.rb

 # frozen_string_literal: true
+
 require "que"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/queue_classic_adapter.rb

 # frozen_string_literal: true
+
 require "queue_classic"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/resque_adapter.rb

 # frozen_string_literal: true
+
 require "resque"
 require "active_support/core_ext/enumerable"
 require "active_support/core_ext/array/access"

activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb

 # frozen_string_literal: true
+
 require "sidekiq"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/sneakers_adapter.rb

 # frozen_string_literal: true
+
 require "sneakers"
 require "monitor"
 

activejob/lib/active_job/queue_adapters/sucker_punch_adapter.rb

 # frozen_string_literal: true
+
 require "sucker_punch"
 
 module ActiveJob

activejob/lib/active_job/queue_adapters/test_adapter.rb

 # frozen_string_literal: true
+
 module ActiveJob
   module QueueAdapters
     # == Test adapter for Active Job

activejob/lib/active_job/queue_name.rb

 # frozen_string_literal: true
+
 module ActiveJob
   module QueueName
     extend ActiveSupport::Concern

activejob/lib/active_job/queue_priority.rb

 # frozen_string_literal: true
+
 module ActiveJob
   module QueuePriority
     extend ActiveSupport::Concern

activejob/lib/active_job/railtie.rb

 # frozen_string_literal: true
+
 require "global_id/railtie"
 require "active_job"
 

activejob/lib/active_job/test_case.rb

 # frozen_string_literal: true
+
 require "active_support/test_case"
 
 module ActiveJob

activejob/lib/active_job/test_helper.rb

 # frozen_string_literal: true
+
 require "active_support/core_ext/class/subclasses"
 require "active_support/core_ext/hash/keys"
 

activejob/lib/active_job/translation.rb

 # frozen_string_literal: true
+
 module ActiveJob
   module Translation #:nodoc:
     extend ActiveSupport::Concern

activejob/lib/active_job/version.rb

 # frozen_string_literal: true
+
 require_relative "gem_version"
 
 module ActiveJob

activejob/lib/rails/generators/job/job_generator.rb

 # frozen_string_literal: true
+
 require "rails/generators/named_base"
 
 module Rails # :nodoc:

activejob/test/adapters/async.rb

 # frozen_string_literal: true
+
 ActiveJob::Base.queue_adapter = :async
 ActiveJob::Base.queue_adapter.immediate = true

activejob/test/adapters/backburner.rb

 # frozen_string_literal: true
+
 require "support/backburner/inline"
 
 ActiveJob::Base.queue_adapter = :backburner

activejob/test/adapters/delayed_job.rb

 # frozen_string_literal: true
+
 ActiveJob::Base.queue_adapter = :delayed_job
 
 $LOAD_PATH << File.expand_path("../support/delayed_job", __dir__)

activejob/test/adapters/inline.rb

 # frozen_string_literal: true
+
 ActiveJob::Base.queue_adapter = :inline

activejob/test/adapters/qu.rb

 # frozen_string_literal: true
+
 require "qu-immediate"
 
 ActiveJob::Base.queue_adapter = :qu

activejob/test/adapters/que.rb

 # frozen_string_literal: true
+
 require "support/que/inline"
 
 ActiveJob::Base.queue_adapter = :que

activejob/test/adapters/queue_classic.rb

 # frozen_string_literal: true
+
 require "support/queue_classic/inline"
 ActiveJob::Base.queue_adapter = :queue_classic

activejob/test/adapters/resque.rb

 # frozen_string_literal: true
+
 ActiveJob::Base.queue_adapter = :resque
 Resque.inline = true

activejob/test/adapters/sidekiq.rb

 # frozen_string_literal: true
+
 require "sidekiq/testing/inline"
 ActiveJob::Base.queue_adapter = :sidekiq

activejob/test/adapters/sneakers.rb

 # frozen_string_literal: true
+
 require "support/sneakers/inline"
 ActiveJob::Base.queue_adapter = :sneakers

activejob/test/adapters/sucker_punch.rb

 # frozen_string_literal: true
+
 require "sucker_punch/testing/inline"
 ActiveJob::Base.queue_adapter = :sucker_punch

activejob/test/adapters/test.rb

 # frozen_string_literal: true
+
 ActiveJob::Base.queue_adapter = :test
 ActiveJob::Base.queue_adapter.perform_enqueued_jobs = true
 ActiveJob::Base.queue_adapter.perform_enqueued_at_jobs = true

activejob/test/cases/adapter_test.rb

 # frozen_string_literal: true
+
 require "helper"
 
 class AdapterTest < ActiveSupport::TestCase

activejob/test/cases/argument_serialization_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "active_job/arguments"
 require "models/person"

activejob/test/cases/callbacks_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/callback_job"
 

activejob/test/cases/exceptions_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/retry_job"
 

activejob/test/cases/job_serialization_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/gid_job"
 require "jobs/hello_job"

activejob/test/cases/logging_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "active_support/log_subscriber/test_helper"
 require "active_support/core_ext/numeric/time"

activejob/test/cases/queue_adapter_test.rb

 # frozen_string_literal: true
+
 require "helper"
 
 module ActiveJob

activejob/test/cases/queue_naming_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/hello_job"
 require "jobs/logging_job"

activejob/test/cases/queue_priority_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/hello_job"
 

activejob/test/cases/queuing_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/hello_job"
 require "active_support/core_ext/numeric/time"

activejob/test/cases/rescue_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/rescue_job"
 require "models/person"

activejob/test/cases/test_case_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/hello_job"
 require "jobs/logging_job"

activejob/test/cases/test_helper_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "active_support/core_ext/time"
 require "active_support/core_ext/date"

activejob/test/cases/translation_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/translated_hello_job"
 

activejob/test/helper.rb

 # frozen_string_literal: true
+
 require "active_job"
 require "support/job_buffer"
 

activejob/test/integration/queuing_test.rb

 # frozen_string_literal: true
+
 require "helper"
 require "jobs/logging_job"
 require "jobs/hello_job"

activejob/test/jobs/application_job.rb

 # frozen_string_literal: true
+
 class ApplicationJob < ActiveJob::Base
 end

activejob/test/jobs/callback_job.rb

 # frozen_string_literal: true
+
 class CallbackJob < ActiveJob::Base
   before_perform ->(job) { job.history << "CallbackJob ran before_perform" }
   after_perform ->(job) { job.history << "CallbackJob ran after_perform" }

activejob/test/jobs/gid_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class GidJob < ActiveJob::Base

activejob/test/jobs/hello_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class HelloJob < ActiveJob::Base

activejob/test/jobs/inherited_job.rb

 # frozen_string_literal: true
+
 require_relative "application_job"
 
 class InheritedJob < ApplicationJob

activejob/test/jobs/kwargs_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class KwargsJob < ActiveJob::Base

activejob/test/jobs/logging_job.rb

 # frozen_string_literal: true
+
 class LoggingJob < ActiveJob::Base
   def perform(dummy)
     logger.info "Dummy, here is it: #{dummy}"

activejob/test/jobs/nested_job.rb

 # frozen_string_literal: true
+
 class NestedJob < ActiveJob::Base
   def perform
     LoggingJob.perform_later "NestedJob"

activejob/test/jobs/overridden_logging_job.rb

 # frozen_string_literal: true
+
 class OverriddenLoggingJob < ActiveJob::Base
   def perform(dummy)
     logger.info "Dummy, here is it: #{dummy}"

activejob/test/jobs/provider_jid_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class ProviderJidJob < ActiveJob::Base

activejob/test/jobs/queue_adapter_job.rb

 # frozen_string_literal: true
+
 class QueueAdapterJob < ActiveJob::Base
   self.queue_adapter = :inline
 end

activejob/test/jobs/queue_as_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class QueueAsJob < ActiveJob::Base

activejob/test/jobs/rescue_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class RescueJob < ActiveJob::Base

activejob/test/jobs/retry_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 require "active_support/core_ext/integer/inflections"
 

activejob/test/jobs/translated_hello_job.rb

 # frozen_string_literal: true
+
 require_relative "../support/job_buffer"
 
 class TranslatedHelloJob < ActiveJob::Base

activejob/test/models/person.rb

 # frozen_string_literal: true
+
 class Person
   class RecordNotFound < StandardError; end
 

activejob/test/support/backburner/inline.rb

 # frozen_string_literal: true
+
 require "backburner"
 
 Backburner::Worker.class_eval do

activejob/test/support/delayed_job/delayed/backend/test.rb

 # frozen_string_literal: true
+
 #copied from https://github.com/collectiveidea/delayed_job/blob/master/spec/delayed/backend/test.rb
 require "ostruct"
 

activejob/test/support/integration/adapters/async.rb

 # frozen_string_literal: true
+
 module AsyncJobsManager
   def setup
     ActiveJob::Base.queue_adapter = :async

activejob/test/support/integration/adapters/backburner.rb

 # frozen_string_literal: true
+
 module BackburnerJobsManager
   def setup
     ActiveJob::Base.queue_adapter = :backburner

activejob/test/support/integration/adapters/delayed_job.rb

 # frozen_string_literal: true
+
 require "delayed_job"
 require "delayed_job_active_record"
 

activejob/test/support/integration/adapters/inline.rb

 # frozen_string_literal: true
+
 module InlineJobsManager
   def setup
     ActiveJob::Base.queue_adapter = :inline

activejob/test/support/integration/adapters/qu.rb

 # frozen_string_literal: true
+
 module QuJobsManager
   def setup
     require "qu-rails"

activejob/test/support/integration/adapters/que.rb

 # frozen_string_literal: true
+
 module QueJobsManager
   def setup
     require "sequel"

activejob/test/support/integration/adapters/queue_classic.rb

 # frozen_string_literal: true
+
 module QueueClassicJobsManager
   def setup
     ENV["QC_DATABASE_URL"] ||= "postgres:///active_jobs_qc_int_test"

activejob/test/support/integration/adapters/resque.rb

 # frozen_string_literal: true
+
 module ResqueJobsManager
   def setup
     ActiveJob::Base.queue_adapter = :resque

activejob/test/support/integration/adapters/sidekiq.rb

 # frozen_string_literal: true
+
 require "sidekiq/api"
 
 require "sidekiq/testing"

activejob/test/support/integration/adapters/sneakers.rb

 # frozen_string_literal: true
+
 require "sneakers/runner"
 require "sneakers/publisher"
 require "timeout"

activejob/test/support/integration/adapters/sucker_punch.rb

 # frozen_string_literal: true
+
 module SuckerPunchJobsManager
   def setup
     ActiveJob::Base.queue_adapter = :sucker_punch

activejob/test/support/integration/dummy_app_template.rb

 # frozen_string_literal: true
+
 if ENV["AJ_ADAPTER"] == "delayed_job"
   generate "delayed_job:active_record", "--quiet"
 end

activejob/test/support/integration/helper.rb

 # frozen_string_literal: true
+
 puts "\n\n*** rake aj:integration:#{ENV['AJ_ADAPTER']} ***\n"
 
 ENV["RAILS_ENV"] = "test"

activejob/test/support/integration/jobs_manager.rb

 # frozen_string_literal: true
+
 class JobsManager
   @@managers = {}
   attr :adapter_name

activejob/test/support/integration/test_case_helpers.rb

 # frozen_string_literal: true
+
 require "active_support/core_ext/string/inflections"
 require "support/integration/jobs_manager"
 

activejob/test/support/job_buffer.rb

 # frozen_string_literal: true
+
 module JobBuffer
   class << self
     def clear

activejob/test/support/que/inline.rb

 # frozen_string_literal: true
+
 require "que"
 
 Que::Job.class_eval do

activejob/test/support/queue_classic/inline.rb

 # frozen_string_literal: true
+
 require "queue_classic"
 
 module QC

activejob/test/support/sneakers/inline.rb

 # frozen_string_literal: true
+
 require "sneakers"
 
 module Sneakers