diff options
Diffstat (limited to 'spec/workers/bulk_imports')
-rw-r--r-- | spec/workers/bulk_imports/pipeline_worker_spec.rb | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/spec/workers/bulk_imports/pipeline_worker_spec.rb b/spec/workers/bulk_imports/pipeline_worker_spec.rb index 3578fec5bc0..209ae8862b6 100644 --- a/spec/workers/bulk_imports/pipeline_worker_spec.rb +++ b/spec/workers/bulk_imports/pipeline_worker_spec.rb @@ -9,7 +9,7 @@ RSpec.describe BulkImports::PipelineWorker do def run; end - def self.ndjson_pipeline? + def self.file_extraction_pipeline? false end end @@ -222,14 +222,14 @@ RSpec.describe BulkImports::PipelineWorker do end end - context 'when ndjson pipeline' do - let(:ndjson_pipeline) do + context 'when file extraction pipeline' do + let(:file_extraction_pipeline) do Class.new do def initialize(_); end def run; end - def self.ndjson_pipeline? + def self.file_extraction_pipeline? true end @@ -249,11 +249,11 @@ RSpec.describe BulkImports::PipelineWorker do end before do - stub_const('NdjsonPipeline', ndjson_pipeline) + stub_const('NdjsonPipeline', file_extraction_pipeline) allow_next_instance_of(BulkImports::Groups::Stage) do |instance| allow(instance).to receive(:pipelines) - .and_return([[0, ndjson_pipeline]]) + .and_return([[0, file_extraction_pipeline]]) end end @@ -278,7 +278,7 @@ RSpec.describe BulkImports::PipelineWorker do expect(described_class) .to receive(:perform_in) .with( - described_class::NDJSON_PIPELINE_PERFORM_DELAY, + described_class::FILE_EXTRACTION_PIPELINE_PERFORM_DELAY, pipeline_tracker.id, pipeline_tracker.stage, entity.id |