diff --git a/src/DataFactory/DataFactoryV2/Changelog.md b/src/DataFactory/DataFactoryV2/Changelog.md index dd1af8a2c48b..9c9123112aee 100644 --- a/src/DataFactory/DataFactoryV2/Changelog.md +++ b/src/DataFactory/DataFactoryV2/Changelog.md @@ -18,6 +18,7 @@ - Additional information about change #1 --> ## Upcoming Release +* Fixed the command `Invoke-AzDataFactoryV2Pipeline` for SupportsShouldProcess issue ## Version 1.11.2 * Updated ADF .Net SDK version to 4.13.0 diff --git a/src/DataFactory/DataFactoryV2/Constants.cs b/src/DataFactory/DataFactoryV2/Constants.cs index a08f47504c2d..41febc683bf5 100644 --- a/src/DataFactory/DataFactoryV2/Constants.cs +++ b/src/DataFactory/DataFactoryV2/Constants.cs @@ -286,5 +286,6 @@ internal static class Constants public const string ActionDescriptionForRemoveEventSubscription = "Unsubscribe the event trigger from external service events."; + public const string ActionDescriptionForInvokePipeline = "Starts a run for \"{0}\" pipeline in the \"{1}\" factory."; } } diff --git a/src/DataFactory/DataFactoryV2/Runs/InvokeAzureDataFactoryPipelineCommand.cs b/src/DataFactory/DataFactoryV2/Runs/InvokeAzureDataFactoryPipelineCommand.cs index 2cc80bdb053b..18429f8a87ea 100644 --- a/src/DataFactory/DataFactoryV2/Runs/InvokeAzureDataFactoryPipelineCommand.cs +++ b/src/DataFactory/DataFactoryV2/Runs/InvokeAzureDataFactoryPipelineCommand.cs @@ -26,7 +26,7 @@ namespace Microsoft.Azure.Commands.DataFactoryV2 { - [Cmdlet("Invoke", ResourceManager.Common.AzureRMConstants.AzureRMPrefix + "DataFactoryV2Pipeline", DefaultParameterSetName = ParameterSetNames.ByFactoryNameByParameterFile,SupportsShouldProcess = true), OutputType(typeof(PSPipeline))] + [Cmdlet("Invoke", ResourceManager.Common.AzureRMConstants.AzureRMPrefix + "DataFactoryV2Pipeline", DefaultParameterSetName = ParameterSetNames.ByFactoryNameByParameterFile, SupportsShouldProcess = true), OutputType(typeof(PSPipeline))] public class InvokeAzureDataFactoryPipelineCommand : DataFactoryBaseCmdlet { [Parameter(ParameterSetName = ParameterSetNames.ByPipelineObjectByParameterFile, Position = 0, Mandatory = true, ValueFromPipeline = true, @@ -157,7 +157,10 @@ public override void ExecuteCmdlet() } } - WriteObject(DataFactoryClient.CreatePipelineRun(ResourceGroupName, DataFactoryName, PipelineName, paramDictionary, ReferencePipelineRunId, isRecovery, StartActivityName, startFromFailure)); + if (ShouldProcess(this.ResourceGroupName, string.Format(Constants.ActionDescriptionForInvokePipeline, this.PipelineName, this.DataFactoryName))) + { + WriteObject(DataFactoryClient.CreatePipelineRun(ResourceGroupName, DataFactoryName, PipelineName, paramDictionary, ReferencePipelineRunId, isRecovery, StartActivityName, startFromFailure)); + } } private Dictionary ReadParametersFromJson()