Skip to content

Commit

Permalink
CLOUDP-272726: Deprecate datalakes pipeline commands
Browse files Browse the repository at this point in the history
  • Loading branch information
blva committed Sep 10, 2024
1 parent ed72504 commit 30db5d0
Show file tree
Hide file tree
Showing 7 changed files with 12 additions and 5 deletions.
11 changes: 6 additions & 5 deletions internal/cli/datalakepipelines/delete.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,11 +53,12 @@ func DeleteBuilder() *cobra.Command {
DeleteOpts: cli.NewDeleteOpts("'%s' deleted\n", "Not deleted"),
}
cmd := &cobra.Command{
Use: "delete <pipelineName>",
Aliases: []string{"rm"},
Short: "Remove the specified data lake pipeline from your project.",
Long: fmt.Sprintf(usage.RequiredRole, "Project Owner"),
Args: require.ExactArgs(1),
Use: "delete <pipelineName>",
Aliases: []string{"rm"},
Short: "Remove the specified data lake pipeline from your project.",
Long: fmt.Sprintf(usage.RequiredRole, "Project Owner"),
Args: require.ExactArgs(1),
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
Annotations: map[string]string{
"pipelineNameDesc": "Label that identifies the pipeline",
"output": opts.SuccessMessage(),
Expand Down
1 change: 1 addition & 0 deletions internal/cli/datalakepipelines/list.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,7 @@ func ListBuilder() *cobra.Command {
Args: require.NoArgs,
Example: `# list all pipelines:
atlas dataLakePipelines list`,
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
PreRunE: func(cmd *cobra.Command, _ []string) error {
return opts.PreRunE(
opts.ValidateProjectID,
Expand Down
1 change: 1 addition & 0 deletions internal/cli/datalakepipelines/pause.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,7 @@ func PauseBuilder() *cobra.Command {
Annotations: map[string]string{
"pipelineNameDesc": "Label that identifies the pipeline",
},
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
Example: `# pause pipeline 'Pipeline1':
atlas dataLakePipelines pause Pipeline1
`,
Expand Down
1 change: 1 addition & 0 deletions internal/cli/datalakepipelines/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,7 @@ func StartBuilder() *cobra.Command {
Annotations: map[string]string{
"pipelineNameDesc": "Label that identifies the pipeline",
},
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
Example: `# start pipeline 'Pipeline1':
atlas dataLakePipelines start Pipeline1
`,
Expand Down
1 change: 1 addition & 0 deletions internal/cli/datalakepipelines/trigger.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,7 @@ func TriggerBuilder() *cobra.Command {
Annotations: map[string]string{
"pipelineNameDesc": "Label that identifies the pipeline",
},
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
Example: `# trigger pipeline 'Pipeline1':
atlas dataLakePipelines trigger Pipeline1
`,
Expand Down
1 change: 1 addition & 0 deletions internal/cli/datalakepipelines/update.go
Original file line number Diff line number Diff line change
Expand Up @@ -155,6 +155,7 @@ func UpdateBuilder() *cobra.Command {
Annotations: map[string]string{
"pipelineNameDesc": "Label that identifies the pipeline",
},
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
Example: `# update data lake pipeline:
atlas dataLakePipelines update Pipeline1 --sinkType CPS --sinkMetadataProvider AWS --sinkMetadataRegion us-east-1 --sinkPartitionField name:0,summary:1 --sourceType PERIODIC_CPS --sourceClusterName Cluster1 --sourceDatabaseName sample_airbnb --sourceCollectionName listingsAndReviews --sourcePolicyItemId 507f1f77bcf86cd799439011 --transform EXCLUDE:space,EXCLUDE:notes`,
PreRunE: func(cmd *cobra.Command, args []string) error {
Expand Down
1 change: 1 addition & 0 deletions internal/cli/datalakepipelines/watch.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,7 @@ func WatchBuilder() *cobra.Command {
"pipelineNameDesc": "Label that identifies the pipeline",
"output": watchTemplate,
},
Deprecated: "Data Lake Pipelines is deprecated. Please see: https://dochub.mongodb.org/core/data-lake-deprecation.",
Example: `# watches the pipeline 'Pipeline1':
atlas dataLakePipelines watch Pipeline1
`,
Expand Down

0 comments on commit 30db5d0

Please sign in to comment.