module ActiveJob::Logging

def logger_tagged_by_active_job?
  logger.formatter.current_tags.include?("ActiveJob")
end

def tag_logger(*tags)
  if logger.respond_to?(:tagged)
    tags.unshift "ActiveJob" unless logger_tagged_by_active_job?
    ActiveJob::Base.logger.tagged(*tags){ yield }
  else
    yield
  end
end