diff options
author | GitLab Bot <gitlab-bot@gitlab.com> | 2022-05-19 10:33:21 +0300 |
---|---|---|
committer | GitLab Bot <gitlab-bot@gitlab.com> | 2022-05-19 10:33:21 +0300 |
commit | 36a59d088eca61b834191dacea009677a96c052f (patch) | |
tree | e4f33972dab5d8ef79e3944a9f403035fceea43f /spec/workers/bulk_imports/pipeline_worker_spec.rb | |
parent | a1761f15ec2cae7c7f7bbda39a75494add0dfd6f (diff) |
Add latest changes from gitlab-org/gitlab@15-0-stable-eev15.0.0-rc42
Diffstat (limited to 'spec/workers/bulk_imports/pipeline_worker_spec.rb')
-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 |