[AutoPR datafactory/resource-manager] [Data Factory] Add data flow compute property in IR.

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

@@ -283,6 +283,7 @@
     from ._models_py3 import IntegrationRuntimeComputeProperties
     from ._models_py3 import IntegrationRuntimeConnectionInfo
     from ._models_py3 import IntegrationRuntimeCustomSetupScriptProperties
+    from ._models_py3 import IntegrationRuntimeDataFlowProperties
     from ._models_py3 import IntegrationRuntimeDataProxyProperties
     from ._models_py3 import IntegrationRuntimeMonitoringData
     from ._models_py3 import IntegrationRuntimeNodeIpAddress
@@ -833,6 +834,7 @@
     from ._models import IntegrationRuntimeComputeProperties
     from ._models import IntegrationRuntimeConnectionInfo
     from ._models import IntegrationRuntimeCustomSetupScriptProperties
+    from ._models import IntegrationRuntimeDataFlowProperties
     from ._models import IntegrationRuntimeDataProxyProperties
     from ._models import IntegrationRuntimeMonitoringData
     from ._models import IntegrationRuntimeNodeIpAddress
@@ -1191,6 +1193,7 @@
     IntegrationRuntimeSsisCatalogPricingTier,
     IntegrationRuntimeLicenseType,
     IntegrationRuntimeEdition,
+    DataFlowComputeType,
     SsisObjectMetadataType,
     IntegrationRuntimeAuthKeyName,
 )
@@ -1469,6 +1472,7 @@
     'IntegrationRuntimeComputeProperties',
     'IntegrationRuntimeConnectionInfo',
     'IntegrationRuntimeCustomSetupScriptProperties',
+    'IntegrationRuntimeDataFlowProperties',
     'IntegrationRuntimeDataProxyProperties',
     'IntegrationRuntimeMonitoringData',
     'IntegrationRuntimeNodeIpAddress',
@@ -1826,6 +1830,7 @@
     'IntegrationRuntimeSsisCatalogPricingTier',
     'IntegrationRuntimeLicenseType',
     'IntegrationRuntimeEdition',
+    'DataFlowComputeType',
     'SsisObjectMetadataType',
     'IntegrationRuntimeAuthKeyName',
 ]

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

@@ -552,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/_models.py

@@ -16059,6 +16059,10 @@ class IntegrationRuntimeComputeProperties(Model):
     :param max_parallel_executions_per_node: Maximum parallel executions count
      per node for managed integration runtime.
     :type max_parallel_executions_per_node: int
+    :param data_flow_properties: Data flow properties for managed integration
+     runtime.
+    :type data_flow_properties:
+     ~azure.mgmt.datafactory.models.IntegrationRuntimeDataFlowProperties
     :param v_net_properties: VNet properties for managed integration runtime.
     :type v_net_properties:
      ~azure.mgmt.datafactory.models.IntegrationRuntimeVNetProperties
@@ -16075,6 +16079,7 @@ class IntegrationRuntimeComputeProperties(Model):
         'node_size': {'key': 'nodeSize', 'type': 'str'},
         'number_of_nodes': {'key': 'numberOfNodes', 'type': 'int'},
         'max_parallel_executions_per_node': {'key': 'maxParallelExecutionsPerNode', 'type': 'int'},
+        'data_flow_properties': {'key': 'dataFlowProperties', 'type': 'IntegrationRuntimeDataFlowProperties'},
         'v_net_properties': {'key': 'vNetProperties', 'type': 'IntegrationRuntimeVNetProperties'},
     }
 
@@ -16085,6 +16090,7 @@ def __init__(self, **kwargs):
         self.node_size = kwargs.get('node_size', None)
         self.number_of_nodes = kwargs.get('number_of_nodes', None)
         self.max_parallel_executions_per_node = kwargs.get('max_parallel_executions_per_node', None)
+        self.data_flow_properties = kwargs.get('data_flow_properties', None)
         self.v_net_properties = kwargs.get('v_net_properties', None)
 
 
@@ -16167,6 +16173,44 @@ def __init__(self, **kwargs):
         self.sas_token = kwargs.get('sas_token', None)
 
 
+class IntegrationRuntimeDataFlowProperties(Model):
+    """Data flow properties for managed integration runtime.
+
+    :param additional_properties: Unmatched properties from the message are
+     deserialized this collection
+    :type additional_properties: dict[str, object]
+    :param compute_type: Compute type of the cluster which will execute data
+     flow job. Possible values include: 'General', 'MemoryOptimized',
+     'ComputeOptimized'
+    :type compute_type: str or
+     ~azure.mgmt.datafactory.models.DataFlowComputeType
+    :param core_count: Core count of the cluster which will execute data flow
+     job. Supported values are: 8, 16, 32, 48, 80, 144 and 272.
+    :type core_count: int
+    :param time_to_live: Time to live (in minutes) setting of the cluster
+     which will execute data flow job.
+    :type time_to_live: int
+    """
+
+    _validation = {
+        'time_to_live': {'minimum': 0},
+    }
+
+    _attribute_map = {
+        'additional_properties': {'key': '', 'type': '{object}'},
+        'compute_type': {'key': 'computeType', 'type': 'str'},
+        'core_count': {'key': 'coreCount', 'type': 'int'},
+        'time_to_live': {'key': 'timeToLive', 'type': 'int'},
+    }
+
+    def __init__(self, **kwargs):
+        super(IntegrationRuntimeDataFlowProperties, self).__init__(**kwargs)
+        self.additional_properties = kwargs.get('additional_properties', None)
+        self.compute_type = kwargs.get('compute_type', None)
+        self.core_count = kwargs.get('core_count', None)
+        self.time_to_live = kwargs.get('time_to_live', None)
+
+
 class IntegrationRuntimeDataProxyProperties(Model):
     """Data proxy properties for a managed dedicated integration runtime.
 

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

@@ -16059,6 +16059,10 @@ class IntegrationRuntimeComputeProperties(Model):
     :param max_parallel_executions_per_node: Maximum parallel executions count
      per node for managed integration runtime.
     :type max_parallel_executions_per_node: int
+    :param data_flow_properties: Data flow properties for managed integration
+     runtime.
+    :type data_flow_properties:
+     ~azure.mgmt.datafactory.models.IntegrationRuntimeDataFlowProperties
     :param v_net_properties: VNet properties for managed integration runtime.
     :type v_net_properties:
      ~azure.mgmt.datafactory.models.IntegrationRuntimeVNetProperties
@@ -16075,16 +16079,18 @@ class IntegrationRuntimeComputeProperties(Model):
         'node_size': {'key': 'nodeSize', 'type': 'str'},
         'number_of_nodes': {'key': 'numberOfNodes', 'type': 'int'},
         'max_parallel_executions_per_node': {'key': 'maxParallelExecutionsPerNode', 'type': 'int'},
+        'data_flow_properties': {'key': 'dataFlowProperties', 'type': 'IntegrationRuntimeDataFlowProperties'},
         'v_net_properties': {'key': 'vNetProperties', 'type': 'IntegrationRuntimeVNetProperties'},
     }
 
-    def __init__(self, *, additional_properties=None, location: str=None, node_size: str=None, number_of_nodes: int=None, max_parallel_executions_per_node: int=None, v_net_properties=None, **kwargs) -> None:
+    def __init__(self, *, additional_properties=None, location: str=None, node_size: str=None, number_of_nodes: int=None, max_parallel_executions_per_node: int=None, data_flow_properties=None, v_net_properties=None, **kwargs) -> None:
         super(IntegrationRuntimeComputeProperties, self).__init__(**kwargs)
         self.additional_properties = additional_properties
         self.location = location
         self.node_size = node_size
         self.number_of_nodes = number_of_nodes
         self.max_parallel_executions_per_node = max_parallel_executions_per_node
+        self.data_flow_properties = data_flow_properties
         self.v_net_properties = v_net_properties
 
 
@@ -16167,6 +16173,44 @@ def __init__(self, *, blob_container_uri: str=None, sas_token=None, **kwargs) ->
         self.sas_token = sas_token
 
 
+class IntegrationRuntimeDataFlowProperties(Model):
+    """Data flow properties for managed integration runtime.
+
+    :param additional_properties: Unmatched properties from the message are
+     deserialized this collection
+    :type additional_properties: dict[str, object]
+    :param compute_type: Compute type of the cluster which will execute data
+     flow job. Possible values include: 'General', 'MemoryOptimized',
+     'ComputeOptimized'
+    :type compute_type: str or
+     ~azure.mgmt.datafactory.models.DataFlowComputeType
+    :param core_count: Core count of the cluster which will execute data flow
+     job. Supported values are: 8, 16, 32, 48, 80, 144 and 272.
+    :type core_count: int
+    :param time_to_live: Time to live (in minutes) setting of the cluster
+     which will execute data flow job.
+    :type time_to_live: int
+    """
+
+    _validation = {
+        'time_to_live': {'minimum': 0},
+    }
+
+    _attribute_map = {
+        'additional_properties': {'key': '', 'type': '{object}'},
+        'compute_type': {'key': 'computeType', 'type': 'str'},
+        'core_count': {'key': 'coreCount', 'type': 'int'},
+        'time_to_live': {'key': 'timeToLive', 'type': 'int'},
+    }
+
+    def __init__(self, *, additional_properties=None, compute_type=None, core_count: int=None, time_to_live: int=None, **kwargs) -> None:
+        super(IntegrationRuntimeDataFlowProperties, self).__init__(**kwargs)
+        self.additional_properties = additional_properties
+        self.compute_type = compute_type
+        self.core_count = core_count
+        self.time_to_live = time_to_live
+
+
 class IntegrationRuntimeDataProxyProperties(Model):
     """Data proxy properties for a managed dedicated integration runtime.