Module: BulkImports::Pipeline

Extended by:

ActiveSupport::Concern

Includes:

Runner, Gitlab::ClassAttributes, Gitlab::Utils::StrongMemoize

Included in:

Common::Pipelines::BadgesPipeline, Common::Pipelines::LfsObjectsPipeline, Common::Pipelines::MembersPipeline, Common::Pipelines::UploadsPipeline, Common::Pipelines::WikiPipeline, Groups::Pipelines::GroupAttributesPipeline, Groups::Pipelines::GroupPipeline, Groups::Pipelines::NamespaceSettingsPipeline, Groups::Pipelines::ProjectEntitiesPipeline, Groups::Pipelines::SubgroupEntitiesPipeline, NdjsonPipeline, BulkImports::Projects::Pipelines::DesignBundlePipeline, BulkImports::Projects::Pipelines::ProjectAttributesPipeline, BulkImports::Projects::Pipelines::ProjectPipeline, BulkImports::Projects::Pipelines::ReferencesPipeline, BulkImports::Projects::Pipelines::RepositoryBundlePipeline, BulkImports::Projects::Pipelines::RepositoryPipeline, BulkImports::Projects::Pipelines::SnippetsRepositoryPipeline

Defined in:

lib/bulk_imports/pipeline.rb,
lib/bulk_imports/pipeline/runner.rb,
lib/bulk_imports/pipeline/context.rb,
lib/bulk_imports/pipeline/extracted_data.rb

Defined Under Namespace

Modules: Runner Classes: Context, ExtractedData

Constant Summary

NotAllowedError =

Class.new(StandardError)

ExpiredError =

Class.new(StandardError)

FailedError =

Class.new(StandardError)

CACHE_KEY_EXPIRATION =

2.hours

NDJSON_EXPORT_TIMEOUT =

90.minutes

EMPTY_EXPORT_STATUS_TIMEOUT =

5.minutes

Constants included from Runner

Runner::MarkedAsFailedError

Instance Method Summary

• #current_user ⇒ Object
• #import_export_config ⇒ Object
• #initialize(context) ⇒ Object
• #portable ⇒ Object
• #tracker ⇒ Object

Methods included from Runner

#run

Instance Method Details

#current_user ⇒ Object

# File 'lib/bulk_imports/pipeline.rb', line 34

def current_user
  @current_user ||= context.current_user
end

#import_export_config ⇒ Object

# File 'lib/bulk_imports/pipeline.rb', line 30

def import_export_config
  @import_export_config ||= context.import_export_config
end

#initialize(context) ⇒ Object

# File 'lib/bulk_imports/pipeline.rb', line 18

def initialize(context)
  @context = context
end

#portable ⇒ Object

# File 'lib/bulk_imports/pipeline.rb', line 26

def portable
  @portable ||= context.portable
end

#tracker ⇒ Object

# File 'lib/bulk_imports/pipeline.rb', line 22

def tracker
  @tracker ||= context.tracker
end