spec/unit/combine_job_spec.rb in elasticrawl-1.0.0 vs spec/unit/combine_job_spec.rb in elasticrawl-1.1.0
- old
+ new
@@ -1,11 +1,11 @@
require 'spec_helper'
describe Elasticrawl::CombineJob do
describe '#set_input_jobs' do
let(:job_name) { (Time.now.to_f * 1000).to_i.to_s }
- let(:crawl) { Elasticrawl::Crawl.create(:crawl_name => 'CC-MAIN-2013-20') }
+ let(:crawl) { Elasticrawl::Crawl.create(:crawl_name => 'CC-MAIN-2014-49') }
let(:segment_list_1) { crawl.crawl_segments[0..1] }
let(:segment_list_2) { [crawl.crawl_segments[2]]}
let(:parse_job_1) { Elasticrawl::ParseJob.new }
let(:parse_job_2) { Elasticrawl::ParseJob.new }
@@ -53,11 +53,11 @@
expect(output_path.include?(combine_job.job_name)).to eq true
end
end
describe '#run' do
- let(:crawl) { Elasticrawl::Crawl.create(:crawl_name => 'CC-MAIN-2013-20') }
+ let(:crawl) { Elasticrawl::Crawl.create(:crawl_name => 'CC-MAIN-2014-49') }
let(:parse_job_1) { Elasticrawl::ParseJob.new }
let(:parse_job_2) { Elasticrawl::ParseJob.new }
let(:combine_job) { Elasticrawl::CombineJob.new }
let(:job_flow_id) { 'j-3QHDKKBT6VAIS' }
@@ -69,18 +69,18 @@
input_jobs = [parse_job_1.job_name, parse_job_2.job_name]
combine_job.set_input_jobs(input_jobs)
end
it 'should set a job flow id' do
- Elasticity::JobFlow.any_instance.stubs(:run).returns(job_flow_id)
+ allow_any_instance_of(Elasticity::JobFlow).to receive(:run).and_return(job_flow_id)
combine_job.run
expect(combine_job.job_flow_id).to eq job_flow_id
end
end
describe '#log_uri' do
- let(:crawl) { Elasticrawl::Crawl.create(:crawl_name => 'CC-MAIN-2013-20') }
+ let(:crawl) { Elasticrawl::Crawl.create(:crawl_name => 'CC-MAIN-2014-49') }
let(:parse_job) { Elasticrawl::ParseJob.new }
let(:job) { Elasticrawl::CombineJob.new }
before do
crawl.create_segments