spec/lib/worker_spec.rb

	worker_spec.rb revision 5a102b3c56d4ac75632c7e9244ee0ce5bdbbf13a
require 'spec_helper'

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

  let(:balancer) { ConcurrencyBalancer.new }

  context 'using the sequential queue' do
    let(:ontology) { create :single_unparsed_ontology }
    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(
        ontology_file('clif/sequential_parse'))
      stub_hets_for('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
        rest_args = ['record', OntologyVersion.to_s, 'parse', version.id]
        Worker.new.perform(
          *rest_args, try_count: ConcurrencyBalancer::MAX_TRIES)
        expect(SequentialWorker.jobs.first['args']).to eq([*rest_args])
      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
        rest_args = ['record', OntologyVersion.to_s, 'parse', version.id]
        Worker.new.perform(
          *rest_args, try_count: ConcurrencyBalancer::MAX_TRIES-1)

        # We need the String-Hash-Key syntax, because
        # the JSON generate/parse cycle does not support
        # symbols
        expect(Worker.jobs.first['args']).to eq([
          *rest_args, "try_count" => ConcurrencyBalancer::MAX_TRIES])
      end
    end
  end

end