[DataFactory] Add 2 New commands to ADF V2 (#13114)

Force merge it because of saving time. CI passed

* Add 2 New commands

* Fix static analysis

* Update Changelog.md

* Update Changelog.md

Co-authored-by: Dingmeng Xue <[email protected]>
Co-authored-by: Yabo Hu <[email protected]>

Author: 3 people

src/DataFactory/DataFactoryV2.Test/Resources/pipelineWait.json

@@ -0,0 +1,15 @@
+{
+  "properties": {
+    "activities": [
+      {
+        "name": "Wait1",
+        "type": "Wait",
+        "dependsOn": [],
+        "userProperties": [],
+        "typeProperties": {
+          "waitTimeInSeconds": 10
+        }
+      }
+    ]
+  }
+}

src/DataFactory/DataFactoryV2.Test/Resources/tumblingTriggerWithPipeline.json

@@ -0,0 +1,18 @@
+{
+  "properties": {
+    "type": "TumblingWindowTrigger",
+    "typeProperties": {
+      "frequency": "Minute",
+      "interval": 15,
+      "startTime": "2019-09-10T13:00:00Z",
+      "endtime": "2019-09-14T13:00:00Z",
+      "maxConcurrency": 2
+    },
+    "pipeline": {
+      "pipelineReference": {
+        "referenceName": "samplePipeline",
+        "type": "PipelineReference"
+      }
+    }
+  }
+}

src/DataFactory/DataFactoryV2.Test/ScenarioTests/TriggerTests.cs

@@ -42,6 +42,13 @@ public void TestStartTriggerThrowsWithoutPipeline()
             RunPowerShellTest(_logger, "Test-StartTriggerThrowsWithoutPipeline");
         }
 
+        [Fact]
+        [Trait(Category.AcceptanceType, Category.CheckIn)]
+        public void TestInvokeAndStopTriggerRun()
+        {
+            RunPowerShellTest(_logger, "Test-TriggerInvokeAndStop");
+        }
+
         [Fact]
         [Trait(Category.AcceptanceType, Category.CheckIn)]
         public void TestTriggerRun()

src/DataFactory/DataFactoryV2.Test/ScenarioTests/TriggerTests.ps1

@@ -338,6 +338,73 @@ function Test-BlobEventTriggerSubscriptionsByResourceId
     }
 }
 
+<#
+.SYNOPSIS
+Creates a TumblingWindow trigger and then does a Get to compare the results.
+Starts and checks that there is at least one Trigger Run
+Reruns the trigger run
+Stops trigger
+Deletes the created trigger at the end.
+#>
+function Test-TriggerInvokeAndStop
+{
+    $dfname = Get-DataFactoryName
+    $rgname = Get-ResourceGroupName
+    $rglocation = Get-ProviderLocation ResourceManagement
+    $dflocation = Get-ProviderLocation DataFactoryManagement
+        
+    New-AzResourceGroup -Name $rgname -Location $rglocation -Force
+
+    try
+    {
+		Get-Command -Name '*AzDataFactoryV2Tr*' | Write-Debug
+        Set-AzDataFactoryV2 -ResourceGroupName $rgname -Name $dfname -Location $dflocation -Force
+
+        $pipelineName = "samplePipeline"   
+        Set-AzDataFactoryV2Pipeline -ResourceGroupName $rgname -Name $pipelineName -DataFactoryName $dfname -File .\Resources\pipelineWait.json -Force
+
+        $triggername = "foo"
+        $expected = Set-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -File .\Resources\tumblingTriggerWithPipeline.json -Force
+        $actual = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Verify-Trigger $expected $actual $rgname $dfname $triggername
+
+        $startDate = [DateTime]::Parse("09/10/2020")
+        Start-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $started = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+        
+        Assert-AreEqual 'Started' $started.RuntimeState 
+        
+        if ([Microsoft.Azure.Test.HttpRecorder.HttpMockServer]::Mode -ne [Microsoft.Azure.Test.HttpRecorder.HttpRecorderMode]::Playback) {
+            Start-Sleep -s 150
+        }
+        
+        $endDate = $startDate.AddYears(1)
+        $triggerRuns = Get-AzDataFactoryV2TriggerRun -ResourceGroupName $rgname -DataFactoryName $dfname -TriggerName $triggername -TriggerRunStartedAfter $startDate -TriggerRunStartedBefore $endDate
+        
+        if($triggerRuns.Count -lt 1)
+        {
+            throw "Expected atleast 1 trigger run"
+        }
+
+		$triggerRunId = $triggerRuns[0].TriggerRunId
+		Invoke-AzDataFactoryV2TriggerRun -ResourceGroupName $rgname -DataFactoryName $dfname -TriggerName $triggername -TriggerRunId $triggerRunId
+
+		Assert-ThrowsContains { Stop-AzDataFactoryV2TriggerRun -ResourceGroupName $rgname -DataFactoryName $dfname -TriggerName $triggername -TriggerRunId $triggerRunId } "not in WaitingOnDependency state" 
+         
+        Stop-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $stopped = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+        
+        Assert-AreEqual 'Stopped' $stopped.RuntimeState 
+
+        Remove-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+    }
+    finally
+    {
+        CleanUp $rgname $dfname
+    }
+}
+
 <#
 .SYNOPSIS
 Creates a trigger and then does a Get with resource id to compare the results.