[Synapse] - Support polling for artifacts cmdlets (Azure#13701)

idear1203 · Dongwei Wang · web-flow · commit 5d651e64fb8d · 2020-12-09T21:53:06.000+08:00
* [Synapse] - Add polling for artifacts operations

* Update changelog

* Clean code

Co-authored-by: Dongwei Wang &lt;dongwwa@microsoft.com&gt;
diff --git a/src/Synapse/Synapse/ChangeLog.md b/src/Synapse/Synapse/ChangeLog.md
@@ -34,6 +34,7 @@
     - Add `Get-AzSynapseSqlPoolTransparentDataEncryption` cmdlet
     - Add `Set-AzSynapseSqlPoolTransparentDataEncryption` cmdlet
 * Fixed deserialization error when create Pipeline/Dataset/Trigger through DefinitionFile
+* Added polling for artifacts cmdlets
 
 ## Version 0.5.0
 * Added support for operation of Synapse SQL Pool Restore Point
diff --git a/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/AddAzureSynapseTriggerSubscription.cs b/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/AddAzureSynapseTriggerSubscription.cs
@@ -59,7 +59,7 @@ public override void ExecuteCmdlet()
 
             if (this.ShouldProcess(this.Name, String.Format(Resources.AddingSynapseTriggerSubscribe, this.Name)))
             {
-                WriteObject(new PSTriggerSubscriptionOperationStatus(SynapseAnalyticsClient.StartSubscribeTriggerToEvents(this.Name)));
+                WriteObject(new PSTriggerSubscriptionOperationStatus(SynapseAnalyticsClient.SubscribeTriggerToEvents(this.Name)));
             }
         }
     }
diff --git a/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/RemoveAzureSynapseTriggerSubscription.cs b/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/RemoveAzureSynapseTriggerSubscription.cs
@@ -70,7 +70,7 @@ public override void ExecuteCmdlet()
                 Name,
                 () =>
                 {
-                    SynapseAnalyticsClient.StartUnsubscribeTriggerFromEvents(this.Name);
+                    SynapseAnalyticsClient.UnsubscribeTriggerFromEvents(this.Name);
                     if (PassThru)
                     {
                         WriteObject(true);
diff --git a/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/StartAzureSynapseTrigger.cs b/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/StartAzureSynapseTrigger.cs
@@ -62,7 +62,7 @@ public override void ExecuteCmdlet()
 
             if (this.ShouldProcess(this.Name, String.Format(Resources.StartingSynapseTrigger, this.Name, this.WorkspaceName)))
             {
-                SynapseAnalyticsClient.StartStartTrigger(this.Name);
+                SynapseAnalyticsClient.StartTrigger(this.Name);
                 if (PassThru)
                 {
                     WriteObject(true);
diff --git a/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/StopAzureSynapseTrigger.cs b/src/Synapse/Synapse/Commands/DataPlaneCommands/Artifact/Triggers/StopAzureSynapseTrigger.cs
@@ -62,7 +62,7 @@ public override void ExecuteCmdlet()
 
             if (this.ShouldProcess(this.Name, String.Format(Resources.StoppingSynapseTrigger, this.Name, this.WorkspaceName)))
             {
-                SynapseAnalyticsClient.StartStopTrigger(this.Name);
+                SynapseAnalyticsClient.StopTrigger(this.Name);
                 if (PassThru)
                 {
                     WriteObject(true);
diff --git a/src/Synapse/Synapse/Common/Utils.cs b/src/Synapse/Synapse/Common/Utils.cs
@@ -1,4 +1,5 @@
-﻿using Microsoft.Azure.Commands.Common.Authentication;
+﻿using Azure;
+using Microsoft.Azure.Commands.Common.Authentication;
 using Microsoft.Azure.Commands.Synapse.Models;
 using Microsoft.Azure.Commands.Synapse.Models.Exceptions;
 using Microsoft.Azure.Commands.Synapse.Properties;
@@ -9,7 +10,6 @@
 using System.Collections;
 using System.Collections.Generic;
 using System.Linq;
-using System.Management.Automation;
 using System.Text.RegularExpressions;
 
 namespace Microsoft.Azure.Commands.Synapse.Common
@@ -172,5 +172,16 @@ public static string[] ProcessExcludedDetectionTypes(string[] excludedDetectionT
             }
             return excludedDetectionTypes;
         }
+
+        public static Operation<T> Poll<T>(this Operation<T> operation)
+        {
+            while (!operation.HasValue)
+            {
+                operation.UpdateStatus();
+                System.Threading.Thread.Sleep(SynapseConstants.DefaultPollingInterval);
+            }
+
+            return operation;
+        }
     }
 }
diff --git a/src/Synapse/Synapse/Models/SynapseAnalyticsArtifactsClient.cs b/src/Synapse/Synapse/Models/SynapseAnalyticsArtifactsClient.cs
@@ -10,9 +10,6 @@
 using System;
 using System.Collections.Generic;
 using System.IO;
-using System.Linq;
-using System.Text;
-using System.Text.Json;
 
 namespace Microsoft.Azure.Commands.Synapse.Models
 {
@@ -73,11 +70,7 @@ public PipelineResource CreateOrUpdatePipeline(string pipelineName, string rawJs
             PSPipelineResource psPipeline = JsonConvert.DeserializeObject<PSPipelineResource>(rawJsonContent,Settings);
             PipelineResource pipeline = psPipeline.ToSdkObject();
             var operation = _pipelineClient.StartCreateOrUpdatePipeline(pipelineName, pipeline);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
         public PipelineResource GetPipeline(string pipelineName)
@@ -92,18 +85,18 @@ public Pageable<PipelineResource> GetPipelinesByWorkspace()
 
         public void DeletePipeline(string pipelineName)
         {
-            _pipelineClient.StartDeletePipeline(pipelineName);
+            _pipelineClient.StartDeletePipeline(pipelineName).Poll();
         }
 
+        #endregion
+
+        #region pipeline run
+
         public CreateRunResponse CreatePipelineRun(string pipelineName, string referencePipelineRunId, bool? isRecovery, string startActivityName, IDictionary<string, object> parameters)
         {
             return _pipelineClient.CreatePipelineRun(pipelineName, referencePipelineRunId, isRecovery, startActivityName, parameters);
         }
 
-        #endregion
-
-        #region pipeline run
-
         public PipelineRun GetPipelineRun(string runId)
         {
             return _pipelineRunClient.GetPipelineRun(runId).Value;
@@ -143,16 +136,12 @@ public LinkedServiceResource CreateOrUpdateLinkedService(string linkedServiceNam
             PSLinkedServiceResource psLinkedService = JsonConvert.DeserializeObject<PSLinkedServiceResource>(rawJsonContent, Settings);
             LinkedServiceResource linkedService = psLinkedService.ToSdkObject();
             var operation = _linkedServiceClient.StartCreateOrUpdateLinkedService(linkedServiceName, linkedService);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
         public void DeleteLinkedService(string linkedServiceName)
         {
-            _linkedServiceClient.StartDeleteLinkedService(linkedServiceName);
+            _linkedServiceClient.StartDeleteLinkedService(linkedServiceName).Poll();
         }
 
         #endregion
@@ -162,16 +151,12 @@ public void DeleteLinkedService(string linkedServiceName)
         public NotebookResource CreateOrUpdateNotebook(string notebookName, NotebookResource notebook)
         {
             var operation = _notebookClient.StartCreateOrUpdateNotebook(notebookName, notebook);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
         public void DeleteNotebook(string notebookName)
         {
-            _notebookClient.StartDeleteNotebook(notebookName);
+            _notebookClient.StartDeleteNotebook(notebookName).Poll();
         }
 
         public NotebookResource GetNotebook(string notebookName)
@@ -193,11 +178,7 @@ public TriggerResource CreateOrUpdateTrigger(string triggerName, string rawJsonC
             PSTriggerResource pSTrigger = JsonConvert.DeserializeObject<PSTriggerResource>(rawJsonContent, Settings);
             TriggerResource trigger = pSTrigger.ToSdkObject();
             var operation = _triggerClient.StartCreateOrUpdateTrigger(triggerName, trigger);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
         public TriggerResource GetTrigger(string triggerName)
@@ -212,37 +193,33 @@ public Pageable<TriggerResource> GetTriggersByWorkspace()
 
         public void DeleteTrigger(string triggerName)
         {
-            _triggerClient.StartDeleteTrigger(triggerName);
+            _triggerClient.StartDeleteTrigger(triggerName).Poll();
         }
 
         public TriggerSubscriptionOperationStatus GetEventSubscriptionStatus(string triggerName)
         {
             return _triggerClient.GetEventSubscriptionStatus(triggerName);
         }
 
-        public TriggerSubscriptionOperationStatus StartSubscribeTriggerToEvents(string triggerName)
+        public TriggerSubscriptionOperationStatus SubscribeTriggerToEvents(string triggerName)
         {
             var operation = _triggerClient.StartSubscribeTriggerToEvents(triggerName);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
-        public void StartUnsubscribeTriggerFromEvents(string triggerName)
+        public void UnsubscribeTriggerFromEvents(string triggerName)
         {
-            _triggerClient.StartUnsubscribeTriggerFromEvents(triggerName);
+            _triggerClient.StartUnsubscribeTriggerFromEvents(triggerName).Poll();
         }
 
-        public void StartStartTrigger(string triggerName)
+        public void StartTrigger(string triggerName)
         {
-            _triggerClient.StartStartTrigger(triggerName);
+            _triggerClient.StartStartTrigger(triggerName).Poll();
         }
 
-        public void StartStopTrigger(string triggerName)
+        public void StopTrigger(string triggerName)
         {
-            _triggerClient.StartStopTrigger(triggerName);
+            _triggerClient.StartStopTrigger(triggerName).Poll();
         }
 
         public IReadOnlyList<TriggerRun> QueryTriggerRunsByWorkspace(RunFilterParameters filterParameters)
@@ -259,11 +236,7 @@ public DatasetResource CreateOrUpdateDataset(string datasetName, string rawJsonC
             PSDatasetResource pSDatasetResource = JsonConvert.DeserializeObject<PSDatasetResource>(rawJsonContent, Settings);
             DatasetResource dataset = pSDatasetResource.ToSdkObject();
             var operation = _datasetClient.StartCreateOrUpdateDataset(datasetName, dataset);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
         public DatasetResource GetDataset(string datasetName)
@@ -278,7 +251,7 @@ public Pageable<DatasetResource> GetDatasetsByWorkspace()
 
         public void DeleteDataset(string datasetName)
         {
-            _datasetClient.StartDeleteDataset(datasetName);
+            _datasetClient.StartDeleteDataset(datasetName).Poll();
         }
 
         #endregion
@@ -290,11 +263,7 @@ public DataFlowResource CreateOrUpdateDataFlow(string dataFlowName, string rawJs
             PSDataFlowResource pSDatasetResource = JsonConvert.DeserializeObject<PSDataFlowResource>(rawJsonContent, Settings);
             DataFlowResource dataFlow = pSDatasetResource.ToSdkObject();
             var operation = _dataFlowClient.StartCreateOrUpdateDataFlow(dataFlowName, dataFlow);
-            while (!operation.HasValue)
-            {
-                operation.UpdateStatus();
-            }
-            return operation.Value;
+            return operation.Poll().Value;
         }
 
         public DataFlowResource GetDataFlow(string dataFlowName)
@@ -309,7 +278,7 @@ public Pageable<DataFlowResource> GetDataFlowsByWorkspace()
 
         public void DeleteDataFlow(string dataFlowName)
         {
-            _dataFlowClient.StartDeleteDataFlow(dataFlowName);
+            _dataFlowClient.StartDeleteDataFlow(dataFlowName).Poll();
         }
 
         #endregion

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ public override void ExecuteCmdlet()`
`59`	`59`
`60`	`60`	`if (this.ShouldProcess(this.Name, String.Format(Resources.AddingSynapseTriggerSubscribe, this.Name)))`
`61`	`61`	`{`
`62`		`- WriteObject(new PSTriggerSubscriptionOperationStatus(SynapseAnalyticsClient.StartSubscribeTriggerToEvents(this.Name)));`
	`62`	`+ WriteObject(new PSTriggerSubscriptionOperationStatus(SynapseAnalyticsClient.SubscribeTriggerToEvents(this.Name)));`
`63`	`63`	`}`
`64`	`64`	`}`
`65`	`65`	`}`
Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ public override void ExecuteCmdlet()`
`70`	`70`	`Name,`
`71`	`71`	`() =>`
`72`	`72`	`{`
`73`		`- SynapseAnalyticsClient.StartUnsubscribeTriggerFromEvents(this.Name);`
	`73`	`+ SynapseAnalyticsClient.UnsubscribeTriggerFromEvents(this.Name);`
`74`	`74`	`if (PassThru)`
`75`	`75`	`{`
`76`	`76`	`WriteObject(true);`
Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ public override void ExecuteCmdlet()`
`62`	`62`
`63`	`63`	`if (this.ShouldProcess(this.Name, String.Format(Resources.StartingSynapseTrigger, this.Name, this.WorkspaceName)))`
`64`	`64`	`{`
`65`		`- SynapseAnalyticsClient.StartStartTrigger(this.Name);`
	`65`	`+ SynapseAnalyticsClient.StartTrigger(this.Name);`
`66`	`66`	`if (PassThru)`
`67`	`67`	`{`
`68`	`68`	`WriteObject(true);`
Original file line number	Diff line number	Diff line change
`@@ -10,9 +10,6 @@`
`10`	`10`	`using System;`
`11`	`11`	`using System.Collections.Generic;`
`12`	`12`	`using System.IO;`
`13`		`-using System.Linq;`
`14`		`-using System.Text;`
`15`		`-using System.Text.Json;`
`16`	`13`
`17`	`14`	`namespace Microsoft.Azure.Commands.Synapse.Models`
`18`	`15`	`{`
`@@ -73,11 +70,7 @@ public PipelineResource CreateOrUpdatePipeline(string pipelineName, string rawJs`
`73`	`70`	`PSPipelineResource psPipeline = JsonConvert.DeserializeObject<PSPipelineResource>(rawJsonContent,Settings);`
`74`	`71`	`PipelineResource pipeline = psPipeline.ToSdkObject();`
`75`	`72`	`var operation = _pipelineClient.StartCreateOrUpdatePipeline(pipelineName, pipeline);`
`76`		`- while (!operation.HasValue)`
`77`		`- {`
`78`		`- operation.UpdateStatus();`
`79`		`- }`
`80`		`- return operation.Value;`
	`73`	`+ return operation.Poll().Value;`
`81`	`74`	`}`
`82`	`75`
`83`	`76`	`public PipelineResource GetPipeline(string pipelineName)`
`@@ -92,18 +85,18 @@ public Pageable<PipelineResource> GetPipelinesByWorkspace()`
`92`	`85`
`93`	`86`	`public void DeletePipeline(string pipelineName)`
`94`	`87`	`{`
`95`		`- _pipelineClient.StartDeletePipeline(pipelineName);`
	`88`	`+ _pipelineClient.StartDeletePipeline(pipelineName).Poll();`
`96`	`89`	`}`
`97`	`90`
	`91`	`+ #endregion`
	`92`	`+`
	`93`	`+ #region pipeline run`
	`94`	`+`
`98`	`95`	`public CreateRunResponse CreatePipelineRun(string pipelineName, string referencePipelineRunId, bool? isRecovery, string startActivityName, IDictionary<string, object> parameters)`
`99`	`96`	`{`
`100`	`97`	`return _pipelineClient.CreatePipelineRun(pipelineName, referencePipelineRunId, isRecovery, startActivityName, parameters);`
`101`	`98`	`}`
`102`	`99`
`103`		`- #endregion`
`104`		`-`
`105`		`- #region pipeline run`
`106`		`-`
`107`	`100`	`public PipelineRun GetPipelineRun(string runId)`
`108`	`101`	`{`
`109`	`102`	`return _pipelineRunClient.GetPipelineRun(runId).Value;`
`@@ -143,16 +136,12 @@ public LinkedServiceResource CreateOrUpdateLinkedService(string linkedServiceNam`
`143`	`136`	`PSLinkedServiceResource psLinkedService = JsonConvert.DeserializeObject<PSLinkedServiceResource>(rawJsonContent, Settings);`
`144`	`137`	`LinkedServiceResource linkedService = psLinkedService.ToSdkObject();`
`145`	`138`	`var operation = _linkedServiceClient.StartCreateOrUpdateLinkedService(linkedServiceName, linkedService);`
`146`		`- while (!operation.HasValue)`
`147`		`- {`
`148`		`- operation.UpdateStatus();`
`149`		`- }`
`150`		`- return operation.Value;`
	`139`	`+ return operation.Poll().Value;`
`151`	`140`	`}`
`152`	`141`
`153`	`142`	`public void DeleteLinkedService(string linkedServiceName)`
`154`	`143`	`{`
`155`		`- _linkedServiceClient.StartDeleteLinkedService(linkedServiceName);`
	`144`	`+ _linkedServiceClient.StartDeleteLinkedService(linkedServiceName).Poll();`
`156`	`145`	`}`
`157`	`146`
`158`	`147`	`#endregion`
`@@ -162,16 +151,12 @@ public void DeleteLinkedService(string linkedServiceName)`
`162`	`151`	`public NotebookResource CreateOrUpdateNotebook(string notebookName, NotebookResource notebook)`
`163`	`152`	`{`
`164`	`153`	`var operation = _notebookClient.StartCreateOrUpdateNotebook(notebookName, notebook);`
`165`		`- while (!operation.HasValue)`
`166`		`- {`
`167`		`- operation.UpdateStatus();`
`168`		`- }`
`169`		`- return operation.Value;`
	`154`	`+ return operation.Poll().Value;`
`170`	`155`	`}`
`171`	`156`
`172`	`157`	`public void DeleteNotebook(string notebookName)`
`173`	`158`	`{`
`174`		`- _notebookClient.StartDeleteNotebook(notebookName);`
	`159`	`+ _notebookClient.StartDeleteNotebook(notebookName).Poll();`
`175`	`160`	`}`
`176`	`161`
`177`	`162`	`public NotebookResource GetNotebook(string notebookName)`
`@@ -193,11 +178,7 @@ public TriggerResource CreateOrUpdateTrigger(string triggerName, string rawJsonC`
`193`	`178`	`PSTriggerResource pSTrigger = JsonConvert.DeserializeObject<PSTriggerResource>(rawJsonContent, Settings);`
`194`	`179`	`TriggerResource trigger = pSTrigger.ToSdkObject();`
`195`	`180`	`var operation = _triggerClient.StartCreateOrUpdateTrigger(triggerName, trigger);`
`196`		`- while (!operation.HasValue)`
`197`		`- {`
`198`		`- operation.UpdateStatus();`
`199`		`- }`
`200`		`- return operation.Value;`
	`181`	`+ return operation.Poll().Value;`
`201`	`182`	`}`
`202`	`183`
`203`	`184`	`public TriggerResource GetTrigger(string triggerName)`
`@@ -212,37 +193,33 @@ public Pageable<TriggerResource> GetTriggersByWorkspace()`
`212`	`193`
`213`	`194`	`public void DeleteTrigger(string triggerName)`
`214`	`195`	`{`
`215`		`- _triggerClient.StartDeleteTrigger(triggerName);`
	`196`	`+ _triggerClient.StartDeleteTrigger(triggerName).Poll();`
`216`	`197`	`}`
`217`	`198`
`218`	`199`	`public TriggerSubscriptionOperationStatus GetEventSubscriptionStatus(string triggerName)`
`219`	`200`	`{`
`220`	`201`	`return _triggerClient.GetEventSubscriptionStatus(triggerName);`
`221`	`202`	`}`
`222`	`203`
`223`		`- public TriggerSubscriptionOperationStatus StartSubscribeTriggerToEvents(string triggerName)`
	`204`	`+ public TriggerSubscriptionOperationStatus SubscribeTriggerToEvents(string triggerName)`
`224`	`205`	`{`
`225`	`206`	`var operation = _triggerClient.StartSubscribeTriggerToEvents(triggerName);`
`226`		`- while (!operation.HasValue)`
`227`		`- {`
`228`		`- operation.UpdateStatus();`
`229`		`- }`
`230`		`- return operation.Value;`
	`207`	`+ return operation.Poll().Value;`
`231`	`208`	`}`
`232`	`209`
`233`		`- public void StartUnsubscribeTriggerFromEvents(string triggerName)`
	`210`	`+ public void UnsubscribeTriggerFromEvents(string triggerName)`
`234`	`211`	`{`
`235`		`- _triggerClient.StartUnsubscribeTriggerFromEvents(triggerName);`
	`212`	`+ _triggerClient.StartUnsubscribeTriggerFromEvents(triggerName).Poll();`
`236`	`213`	`}`
`237`	`214`
`238`		`- public void StartStartTrigger(string triggerName)`
	`215`	`+ public void StartTrigger(string triggerName)`
`239`	`216`	`{`
`240`		`- _triggerClient.StartStartTrigger(triggerName);`
	`217`	`+ _triggerClient.StartStartTrigger(triggerName).Poll();`
`241`	`218`	`}`
`242`	`219`
`243`		`- public void StartStopTrigger(string triggerName)`
	`220`	`+ public void StopTrigger(string triggerName)`
`244`	`221`	`{`
`245`		`- _triggerClient.StartStopTrigger(triggerName);`
	`222`	`+ _triggerClient.StartStopTrigger(triggerName).Poll();`
`246`	`223`	`}`
`247`	`224`
`248`	`225`	`public IReadOnlyList<TriggerRun> QueryTriggerRunsByWorkspace(RunFilterParameters filterParameters)`
`@@ -259,11 +236,7 @@ public DatasetResource CreateOrUpdateDataset(string datasetName, string rawJsonC`
`259`	`236`	`PSDatasetResource pSDatasetResource = JsonConvert.DeserializeObject<PSDatasetResource>(rawJsonContent, Settings);`
`260`	`237`	`DatasetResource dataset = pSDatasetResource.ToSdkObject();`
`261`	`238`	`var operation = _datasetClient.StartCreateOrUpdateDataset(datasetName, dataset);`
`262`		`- while (!operation.HasValue)`
`263`		`- {`
`264`		`- operation.UpdateStatus();`
`265`		`- }`
`266`		`- return operation.Value;`
	`239`	`+ return operation.Poll().Value;`
`267`	`240`	`}`
`268`	`241`
`269`	`242`	`public DatasetResource GetDataset(string datasetName)`
`@@ -278,7 +251,7 @@ public Pageable<DatasetResource> GetDatasetsByWorkspace()`
`278`	`251`
`279`	`252`	`public void DeleteDataset(string datasetName)`
`280`	`253`	`{`
`281`		`- _datasetClient.StartDeleteDataset(datasetName);`
	`254`	`+ _datasetClient.StartDeleteDataset(datasetName).Poll();`
`282`	`255`	`}`
`283`	`256`
`284`	`257`	`#endregion`
`@@ -290,11 +263,7 @@ public DataFlowResource CreateOrUpdateDataFlow(string dataFlowName, string rawJs`
`290`	`263`	`PSDataFlowResource pSDatasetResource = JsonConvert.DeserializeObject<PSDataFlowResource>(rawJsonContent, Settings);`
`291`	`264`	`DataFlowResource dataFlow = pSDatasetResource.ToSdkObject();`
`292`	`265`	`var operation = _dataFlowClient.StartCreateOrUpdateDataFlow(dataFlowName, dataFlow);`
`293`		`- while (!operation.HasValue)`
`294`		`- {`
`295`		`- operation.UpdateStatus();`
`296`		`- }`
`297`		`- return operation.Value;`
	`266`	`+ return operation.Poll().Value;`
`298`	`267`	`}`
`299`	`268`
`300`	`269`	`public DataFlowResource GetDataFlow(string dataFlowName)`
`@@ -309,7 +278,7 @@ public Pageable<DataFlowResource> GetDataFlowsByWorkspace()`
`309`	`278`
`310`	`279`	`public void DeleteDataFlow(string dataFlowName)`
`311`	`280`	`{`
`312`		`- _dataFlowClient.StartDeleteDataFlow(dataFlowName);`
	`281`	`+ _dataFlowClient.StartDeleteDataFlow(dataFlowName).Poll();`
`313`	`282`	`}`
`314`	`283`
`315`	`284`	`#endregion`