diff options
Diffstat (limited to 'app/workers/bulk_import_worker.rb')
-rw-r--r-- | app/workers/bulk_import_worker.rb | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/app/workers/bulk_import_worker.rb b/app/workers/bulk_import_worker.rb index e6bc54895a7..b4b9d9b05c1 100644 --- a/app/workers/bulk_import_worker.rb +++ b/app/workers/bulk_import_worker.rb @@ -21,9 +21,11 @@ class BulkImportWorker # rubocop:disable Scalability/IdempotentWorker @bulk_import.start! if @bulk_import.created? created_entities.first(next_batch_size).each do |entity| - entity.start! + create_pipeline_tracker_for(entity) BulkImports::EntityWorker.perform_async(entity.id) + + entity.start! end re_enqueue @@ -65,4 +67,13 @@ class BulkImportWorker # rubocop:disable Scalability/IdempotentWorker def re_enqueue BulkImportWorker.perform_in(PERFORM_DELAY, @bulk_import.id) end + + def create_pipeline_tracker_for(entity) + BulkImports::Stage.pipelines.each do |stage, pipeline| + entity.trackers.create!( + stage: stage, + pipeline_name: pipeline + ) + end + end end |