1 files changed, 7 insertions, 3 deletions
diff --git a/spec/lib/bulk_imports/pipeline/runner_spec.rb b/spec/lib/bulk_imports/pipeline/runner_spec.rb
index 810271818ae..a5a01354d0e 100644
--- a/spec/lib/bulk_imports/pipeline/runner_spec.rb
+++ b/spec/lib/bulk_imports/pipeline/runner_spec.rb
@@ -60,7 +60,9 @@ RSpec.describe BulkImports::Pipeline::Runner do
               pipeline_step: :extractor,
               pipeline_class: 'BulkImports::MyPipeline',
               exception_class: exception_class,
-              exception_message: exception_message
+              exception_message: exception_message,
+              message: "Pipeline failed",
+              importer: 'gitlab_migration'
             )
           )
       end
@@ -89,7 +91,8 @@ RSpec.describe BulkImports::Pipeline::Runner do
               log_params(
                 context,
                 message: 'Aborting entity migration due to pipeline failure',
-                pipeline_class: 'BulkImports::MyPipeline'
+                pipeline_class: 'BulkImports::MyPipeline',
+                importer: 'gitlab_migration'
               )
             )
         end
@@ -290,9 +293,10 @@ RSpec.describe BulkImports::Pipeline::Runner do
 
     def log_params(context, extra = {})
       {
-        bulk_import_id: context.bulk_import.id,
+        bulk_import_id: context.bulk_import_id,
         bulk_import_entity_id: context.entity.id,
         bulk_import_entity_type: context.entity.source_type,
+        importer: 'gitlab_migration',
         context_extra: context.extra
       }.merge(extra)
     end