Class: BulkImports::Projects::Pipelines::ReferencesPipeline

Inherits:
Object
  • Object
show all
Includes:
BulkImports::Pipeline
Defined in:
lib/bulk_imports/projects/pipelines/references_pipeline.rb

Constant Summary collapse

BATCH_SIZE = 
100
DELAY = 
1.second

Constants included from BulkImports::Pipeline

BulkImports::Pipeline::CACHE_KEY_EXPIRATION, BulkImports::Pipeline::EMPTY_EXPORT_STATUS_TIMEOUT, BulkImports::Pipeline::ExpiredError, BulkImports::Pipeline::FailedError, BulkImports::Pipeline::NDJSON_EXPORT_TIMEOUT, BulkImports::Pipeline::NotAllowedError

Constants included from BulkImports::Pipeline::Runner

BulkImports::Pipeline::Runner::MarkedAsFailedError

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from BulkImports::Pipeline

#current_user, #import_export_config, #initialize, #portable, #tracker

Methods included from BulkImports::Pipeline::Runner

#on_finish, #run

Instance Attribute Details

#tracker_id ⇒ Object (readonly)

Returns the value of attribute tracker_id.



22
23
24
 
# File 'lib/bulk_imports/projects/pipelines/references_pipeline.rb', line 22

def tracker_id
  @tracker_id
end

Instance Method Details

#extract(context) ⇒ Object 



12
13
14
15
16
17
18
19
20
 
# File 'lib/bulk_imports/projects/pipelines/references_pipeline.rb', line 12

def extract(context)
  @tracker_id = context.tracker.id
  @counter = 0

  enqueue_ref_workers_for_issues_and_issue_notes
  enqueue_ref_workers_for_merge_requests_and_merge_request_notes

  nil
end