diff options
Diffstat (limited to 'lib/bulk_imports/stage.rb')
-rw-r--r-- | lib/bulk_imports/stage.rb | 54 |
1 files changed, 3 insertions, 51 deletions
diff --git a/lib/bulk_imports/stage.rb b/lib/bulk_imports/stage.rb index b1bceecbaea..103623cd030 100644 --- a/lib/bulk_imports/stage.rb +++ b/lib/bulk_imports/stage.rb @@ -2,55 +2,8 @@ module BulkImports class Stage - include Singleton - - CONFIG = { - group: { - pipeline: BulkImports::Groups::Pipelines::GroupPipeline, - stage: 0 - }, - avatar: { - pipeline: BulkImports::Groups::Pipelines::GroupAvatarPipeline, - stage: 1 - }, - subgroups: { - pipeline: BulkImports::Groups::Pipelines::SubgroupEntitiesPipeline, - stage: 1 - }, - members: { - pipeline: BulkImports::Groups::Pipelines::MembersPipeline, - stage: 1 - }, - labels: { - pipeline: BulkImports::Groups::Pipelines::LabelsPipeline, - stage: 1 - }, - milestones: { - pipeline: BulkImports::Groups::Pipelines::MilestonesPipeline, - stage: 1 - }, - badges: { - pipeline: BulkImports::Groups::Pipelines::BadgesPipeline, - stage: 1 - }, - boards: { - pipeline: BulkImports::Groups::Pipelines::BoardsPipeline, - stage: 2 - }, - finisher: { - pipeline: BulkImports::Groups::Pipelines::EntityFinisher, - stage: 3 - } - }.freeze - def self.pipelines - instance.pipelines - end - - def self.pipeline_exists?(name) - pipelines.any? do |(_, pipeline)| - pipeline.to_s == name.to_s - end + new.pipelines end def pipelines @@ -65,9 +18,8 @@ module BulkImports private def config - @config ||= CONFIG + # To be implemented in a sub-class + NotImplementedError end end end - -::BulkImports::Stage.prepend_mod_with('BulkImports::Stage') |