spec/lib/ontology_batch_parse_worker_spec.rb

	ontology_batch_parse_worker_spec.rb revision 20d7141b5fbf4ea48eeadae9d6a9a88465ac6b8b
require 'spec_helper'

# We try to be explicit when using sidekiq
# testing modes. However inline! is the default
describe OntologyBatchParseWorker do

  let(:balancer) { ConcurrencyBalancer.new }

  context 'using the sequential queue' do
    let(:ontology) { create :single_unparsed_ontology, iri: 'http://example.com/test/sequential_parse' }
    let(:version) { ontology.versions.last }

    before do
      begin
        balancer.mark_as_finished_processing(ontology.iri)
      rescue ConcurrencyBalancer::UnmarkedProcessingError
      end
      balancer.mark_as_processing_or_complain(ontology.iri)
      OntologyVersion.any_instance.stubs(:raw_path!).returns(
        Rails.root + 'test/fixtures/ontologies/clif/sequential_parse.clif')
    end

    after do
      balancer.mark_as_finished_processing(ontology.iri)
      OntologyVersion.any_instance.unstub(:raw_path!)
    end

    context 'exceeding the parallel try count of an already marked iri job' do
      it 'should put the correct job in the sequential queue' do
        optioned_versions = [[version.id, {"fast_parse" => version.fast_parse}]]
        OntologyBatchParseWorker.new.perform(
          optioned_versions, try_count: ConcurrencyBalancer::MAX_TRIES)
        expect(SequentialOntologyBatchParseWorker.jobs.first['args']).to eq([optioned_versions])
      end
    end

    context 'not exceeding the parallel try count of an already marked iri job' do
      it 'should put the correct job in the queue once again' do
        optioned_versions = [[version.id, {"fast_parse" => version.fast_parse}]]
        OntologyBatchParseWorker.new.perform(
          optioned_versions, try_count: ConcurrencyBalancer::MAX_TRIES-1)
        expect(OntologyBatchParseWorker.jobs.first['args']).to eq([
          optioned_versions, "try_count" => ConcurrencyBalancer::MAX_TRIES])
      end
    end
  end

end