summaryrefslogtreecommitdiff
path: root/spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb
diff options
context:
space:
mode:
Diffstat (limited to 'spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb')
-rw-r--r--spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb10
1 files changed, 4 insertions, 6 deletions
diff --git a/spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb b/spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb
index 2c1af4f8948..04b694dc0cb 100644
--- a/spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb
+++ b/spec/lib/gitlab/github_import/importer/issue_events_importer_spec.rb
@@ -2,7 +2,7 @@
require 'spec_helper'
-RSpec.describe Gitlab::GithubImport::Importer::IssueEventsImporter do
+RSpec.describe Gitlab::GithubImport::Importer::IssueEventsImporter, feature_category: :importers do
subject(:importer) { described_class.new(project, client, parallel: parallel) }
let(:project) { instance_double(Project, id: 4, import_source: 'foo/bar') }
@@ -73,14 +73,12 @@ RSpec.describe Gitlab::GithubImport::Importer::IssueEventsImporter do
end
end
- describe '#parallel_import' do
+ describe '#parallel_import', :clean_gitlab_redis_cache do
it 'imports each note in parallel' do
allow(importer).to receive(:each_object_to_import).and_yield(issue_event)
- expect(Gitlab::GithubImport::ImportIssueEventWorker).to receive(:bulk_perform_in).with(
- 1.second, [
- [project.id, an_instance_of(Hash), an_instance_of(String)]
- ], batch_size: 1000, batch_delay: 1.minute
+ expect(Gitlab::GithubImport::ImportIssueEventWorker).to receive(:perform_in).with(
+ 1.second, project.id, an_instance_of(Hash), an_instance_of(String)
)
waiter = importer.parallel_import