[AutoPR datafactory/resource-manager] [DataFactory] Changing arguments to object to support oneOf - this will allow param…

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_data_factory_management_client.py

@@ -27,6 +27,8 @@
 from .operations import TriggersOperations
 from .operations import TriggerRunsOperations
 from .operations import RerunTriggersOperations
+from .operations import DataFlowsOperations
+from .operations import DataFlowDebugSessionOperations
 from . import models
 
 
@@ -64,6 +66,10 @@ class DataFactoryManagementClient(SDKClient):
     :vartype trigger_runs: azure.mgmt.datafactory.operations.TriggerRunsOperations
     :ivar rerun_triggers: RerunTriggers operations
     :vartype rerun_triggers: azure.mgmt.datafactory.operations.RerunTriggersOperations
+    :ivar data_flows: DataFlows operations
+    :vartype data_flows: azure.mgmt.datafactory.operations.DataFlowsOperations
+    :ivar data_flow_debug_session: DataFlowDebugSession operations
+    :vartype data_flow_debug_session: azure.mgmt.datafactory.operations.DataFlowDebugSessionOperations
 
     :param credentials: Credentials needed for the client to connect to Azure.
     :type credentials: :mod:`A msrestazure Credentials
@@ -112,3 +118,7 @@ def __init__(
             self._client, self.config, self._serialize, self._deserialize)
         self.rerun_triggers = RerunTriggersOperations(
             self._client, self.config, self._serialize, self._deserialize)
+        self.data_flows = DataFlowsOperations(
+            self._client, self.config, self._serialize, self._deserialize)
+        self.data_flow_debug_session = DataFlowDebugSessionOperations(
+            self._client, self.config, self._serialize, self._deserialize)

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py

@@ -124,6 +124,13 @@ class TriggerRunStatus(str, Enum):
     inprogress = "Inprogress"
 
 
+class DataFlowDebugCommandType(str, Enum):
+
+    execute_preview_query = "executePreviewQuery"
+    execute_statistics_query = "executeStatisticsQuery"
+    execute_expression_query = "executeExpressionQuery"
+
+
 class TumblingWindowFrequency(str, Enum):
 
     minute = "Minute"
@@ -370,6 +377,19 @@ class WebActivityMethod(str, Enum):
     delete = "DELETE"
 
 
+class OraclePartitionOption(str, Enum):
+
+    none = "None"
+    physical_partitions_of_table = "PhysicalPartitionsOfTable"
+    dynamic_range = "DynamicRange"
+
+
+class SalesforceSourceReadBehavior(str, Enum):
+
+    query = "Query"
+    query_all = "QueryAll"
+
+
 class NetezzaPartitionOption(str, Enum):
 
     none = "None"
@@ -398,13 +418,6 @@ class TeradataPartitionOption(str, Enum):
     dynamic_range = "DynamicRange"
 
 
-class OraclePartitionOption(str, Enum):
-
-    none = "None"
-    physical_partitions_of_table = "PhysicalPartitionsOfTable"
-    dynamic_range = "DynamicRange"
-
-
 class StoredProcedureParameterType(str, Enum):
 
     string = "String"
@@ -426,12 +439,6 @@ class SapTablePartitionOption(str, Enum):
     partition_on_time = "PartitionOnTime"
 
 
-class SalesforceSourceReadBehavior(str, Enum):
-
-    query = "Query"
-    query_all = "QueryAll"
-
-
 class SsisPackageLocationType(str, Enum):
 
     ssisdb = "SSISDB"
@@ -545,6 +552,13 @@ class IntegrationRuntimeEdition(str, Enum):
     enterprise = "Enterprise"
 
 
+class DataFlowComputeType(str, Enum):
+
+    general = "General"
+    memory_optimized = "MemoryOptimized"
+    compute_optimized = "ComputeOptimized"
+
+
 class SsisObjectMetadataType(str, Enum):
 
     folder = "Folder"

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_paged_models.py

@@ -116,3 +116,29 @@ class RerunTriggerResourcePaged(Paged):
     def __init__(self, *args, **kwargs):
 
         super(RerunTriggerResourcePaged, self).__init__(*args, **kwargs)
+class DataFlowResourcePaged(Paged):
+    """
+    A paging container for iterating over a list of :class:`DataFlowResource <azure.mgmt.datafactory.models.DataFlowResource>` object
+    """
+
+    _attribute_map = {
+        'next_link': {'key': 'nextLink', 'type': 'str'},
+        'current_page': {'key': 'value', 'type': '[DataFlowResource]'}
+    }
+
+    def __init__(self, *args, **kwargs):
+
+        super(DataFlowResourcePaged, self).__init__(*args, **kwargs)
+class DataFlowDebugSessionInfoPaged(Paged):
+    """
+    A paging container for iterating over a list of :class:`DataFlowDebugSessionInfo <azure.mgmt.datafactory.models.DataFlowDebugSessionInfo>` object
+    """
+
+    _attribute_map = {
+        'next_link': {'key': 'nextLink', 'type': 'str'},
+        'current_page': {'key': 'value', 'type': '[DataFlowDebugSessionInfo]'}
+    }
+
+    def __init__(self, *args, **kwargs):
+
+        super(DataFlowDebugSessionInfoPaged, self).__init__(*args, **kwargs)

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/operations/__init__.py

@@ -23,6 +23,8 @@
 from ._triggers_operations import TriggersOperations
 from ._trigger_runs_operations import TriggerRunsOperations
 from ._rerun_triggers_operations import RerunTriggersOperations
+from ._data_flows_operations import DataFlowsOperations
+from ._data_flow_debug_session_operations import DataFlowDebugSessionOperations
 
 __all__ = [
     'Operations',
@@ -39,4 +41,6 @@
     'TriggersOperations',
     'TriggerRunsOperations',
     'RerunTriggersOperations',
+    'DataFlowsOperations',
+    'DataFlowDebugSessionOperations',
 ]