Sha256: 7ecd398e98a7b711935076f23fcbb991270f9bfcf043e2d0d5c49723962845f9
Contents?: true
Size: 1.46 KB
Versions: 8
Compression:
Stored size: 1.46 KB
Contents
require 'test_helper'
class WorkerTest < Test::Unit::TestCase
context "A CloudCrowd::Worker" do
setup do
@node = Node.new.instance_variable_get(:"@instance")
@unit = WorkUnit.make!
@worker = Worker.new(@node, JSON.parse(@unit.to_json))
end
should "instantiate correctly" do
assert @worker.pid == $$
assert @worker.unit['id'] == @unit.id
assert @worker.status == @unit.status
assert @worker.node == @node
assert @worker.time_taken > 0
end
should "be able to retry operations that must succeed" do
@worker.instance_variable_set :@retry_wait, 0.01
@worker.expects(:log).at_least(3)
tries = 0
@worker.keep_trying_to("do something critical") do
tries += 1;
raise 'hell' unless tries > 3
assert "made it through"
end
end
should "be able to run an action and try to complete it" do
GraphicsMagick.any_instance.expects(:process).returns('the answer')
GraphicsMagick.any_instance.expects(:cleanup_work_directory)
@worker.expects(:complete_work_unit).with({'output' => 'the answer'}.to_json)
@worker.run_work_unit
end
should "enchance the options that an action receives with extra info" do
opts = @worker.enhanced_unit_options
assert opts['work_unit_id'] == @unit.id
assert opts['job_id'] == @unit.job.id
assert opts['attempts'] == @unit.attempts
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems