spec/lib/worker_spec.rb

	worker_spec.rb revision a9a53dbe70810d1bf7d91ed2af86dd6d39a13124


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
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, locid: '/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(
        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