1
0
Fork 0
mirror of https://github.com/rails/rails.git synced 2022-11-09 12:12:34 -05:00
rails--rails/activejob/test/cases/job_serialization_test.rb
Cory Gwin @gwincr11 31021c780f
Adding enque time tracking and logging
Motivation:
  - Currently we have 2 seperate monkey patches in place for tracking
  enqueded time for 2 seperate workers. It seems that activejob could be
  a source of truth for how long an item has been enqued so that we can
  easily use it for consistent monitoring across workers/apps to ensure
  that jobs are running at an acceptable speed.

Changes:
  - Add an enqueded at attribute and serilization tooling.
  - Add a method to get how long a job has been enqueded for.
  - Add a logging item to show how long a job was enqued prior to the
  perform method firing.
2019-02-13 19:20:41 -05:00

75 lines
2 KiB
Ruby

# frozen_string_literal: true
require "helper"
require "jobs/gid_job"
require "jobs/hello_job"
require "models/person"
require "json"
class JobSerializationTest < ActiveSupport::TestCase
setup do
JobBuffer.clear
@person = Person.find(5)
end
test "serialize job with gid" do
GidJob.perform_later @person
assert_equal "Person with ID: 5", JobBuffer.last_value
end
test "serialize includes current locale" do
assert_equal "en", HelloJob.new.serialize["locale"]
end
test "serialize and deserialize are symmetric" do
# Round trip a job in memory only
h1 = HelloJob.new("Rafael")
h2 = HelloJob.deserialize(h1.serialize)
assert_equal h1.serialize, h2.serialize
# Now verify it's identical to a JSON round trip.
# We don't want any non-native JSON elements in the job hash,
# like symbols.
payload = JSON.dump(h2.serialize)
h3 = HelloJob.deserialize(JSON.load(payload))
assert_equal h2.serialize, h3.serialize
end
test "deserialize sets locale" do
job = HelloJob.new
job.deserialize "locale" => "es"
assert_equal "es", job.locale
end
test "deserialize sets default locale" do
job = HelloJob.new
job.deserialize({})
assert_equal "en", job.locale
end
test "serialize stores provider_job_id" do
job = HelloJob.new
assert_nil job.serialize["provider_job_id"]
job.provider_job_id = "some value set by adapter"
assert_equal job.provider_job_id, job.serialize["provider_job_id"]
end
test "serialize stores the current timezone" do
Time.use_zone "Hawaii" do
job = HelloJob.new
assert_equal "Hawaii", job.serialize["timezone"]
end
end
test "serialize stores the enqueued_at time" do
h1 = HelloJob.new
type = h1.serialize["enqueued_at"].class
assert_equal String, type
h2 = HelloJob.deserialize(h1.serialize)
# We should be able to parse a timestamp
type = Time.parse(h2.enqueued_at).class
assert_equal Time, type
end
end