Class: BulkImports::Projects::Pipelines::ProjectPipeline

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

Constant Summary

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 Method Summary collapse

Methods included from BulkImports::Pipeline

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

Methods included from BulkImports::Pipeline::Runner

#run

Instance Method Details

#load(context, data) ⇒ Object



15
16
17
18
19
20
21
22
23
24
25
# File 'lib/bulk_imports/projects/pipelines/project_pipeline.rb', line 15

def load(context, data)
  project = ::Projects::CreateService.new(context.current_user, data).execute

  if project.persisted?
    context.entity.update!(project: project)

    project
  else
    raise(::BulkImports::Error, "Unable to import project #{project.full_path}. #{project.errors.full_messages}.")
  end
end