Sha256: 5e52afd89557738dd48d75ff1973111321cbd70acc3c2bfe09062efde5ac11dd
Contents?: true
Size: 1.2 KB
Versions: 33
Compression:
Stored size: 1.2 KB
Contents
require 'test_helper'
class WordCountTest < Test::Unit::TestCase
context "the word_count action" do
setup do
WorkUnit.expects(:distribute_to_nodes).returns(true)
@asset_store = AssetStore.new
@browser = Rack::Test::Session.new(Rack::MockSession.new(CloudCrowd::Server))
@browser.put('/worker', :name => 'test_worker', :thread_status => 'sleeping')
post_job_to_count_words_in_this_file
@job_id = JSON.parse(@browser.last_response.body)['id']
end
should "be able to create a word_count job" do
assert @browser.last_response.ok?
info = JSON.parse(@browser.last_response.body)
assert info['status'] == 'processing'
assert info['work_units'] == 1
end
should "be able to perform the processing stage of a word_count" do
action = CloudCrowd.actions['word_count'].new(1, "file://#{File.expand_path(__FILE__)}", {}, @asset_store)
count = action.process
assert count == 101
end
end
def post_job_to_count_words_in_this_file
@browser.post '/jobs', :job => {
'action' => 'word_count',
'inputs' => ["file://#{File.expand_path(__FILE__)}"],
'options' => {}
}.to_json
end
end
Version data entries
33 entries across 33 versions & 3 rubygems