1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
# frozen_string_literal: true
module BulkImports
module Groups
class Stage < ::BulkImports::Stage
private
# To skip the execution of a pipeline in a specific source instance version, define the attributes
# `minimum_source_version` and `maximum_source_version`.
#
# Use the `minimum_source_version` to inform that the pipeline needs to run when importing from source instances
# version greater than or equal to the specified minimum source version. For example, if the
# `minimum_source_version` is equal to 15.1.0, the pipeline will be executed when importing from source instances
# running versions 15.1.0, 15.1.1, 15.2.0, 16.0.0, etc. And it won't be executed when the source instance version
# is 15.0.1, 15.0.0, 14.10.0, etc.
#
# Use the `maximum_source_version` to inform that the pipeline needs to run when importing from source instance
# versions less than or equal to the specified maximum source version. For example, if the
# `maximum_source_version` is equal to 15.1.0, the pipeline will be executed when importing from source instances
# running versions 15.1.1 (patch), 15.1.0, 15.0.1, 15.0.0, 14.10.0, etc. And it won't be executed when the source
# instance version is 15.2.0, 15.2.1, 16.0.0, etc.
def config
{
group: {
pipeline: BulkImports::Groups::Pipelines::GroupPipeline,
stage: 0
},
group_attributes: {
pipeline: BulkImports::Groups::Pipelines::GroupAttributesPipeline,
stage: 1
},
subgroups: {
pipeline: BulkImports::Groups::Pipelines::SubgroupEntitiesPipeline,
stage: 1
},
namespace_settings: {
pipeline: BulkImports::Groups::Pipelines::NamespaceSettingsPipeline,
stage: 1,
minimum_source_version: '15.0.0'
},
members: {
pipeline: BulkImports::Common::Pipelines::MembersPipeline,
stage: 1
},
labels: {
pipeline: BulkImports::Common::Pipelines::LabelsPipeline,
stage: 1
},
milestones: {
pipeline: BulkImports::Common::Pipelines::MilestonesPipeline,
stage: 1
},
badges: {
pipeline: BulkImports::Common::Pipelines::BadgesPipeline,
stage: 1
},
boards: {
pipeline: BulkImports::Common::Pipelines::BoardsPipeline,
stage: 2
},
uploads: {
pipeline: BulkImports::Common::Pipelines::UploadsPipeline,
stage: 2
},
finisher: {
pipeline: BulkImports::Common::Pipelines::EntityFinisher,
stage: 3
}
}.merge(project_entities_pipeline)
end
def project_entities_pipeline
if project_pipeline_available? && feature_flag_enabled?
{
project_entities: {
pipeline: BulkImports::Groups::Pipelines::ProjectEntitiesPipeline,
stage: 1
}
}
else
{}
end
end
def project_pipeline_available?
@bulk_import.source_version_info >= BulkImport.min_gl_version_for_project_migration
end
def feature_flag_enabled?
destination_namespace = @bulk_import_entity.destination_namespace
BulkImports::Features.project_migration_enabled?(destination_namespace)
end
end
end
end
::BulkImports::Groups::Stage.prepend_mod_with('BulkImports::Groups::Stage')
|
