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