[AutoPR datafactory/resource-manager] Add two API-s to integration runtime

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

@@ -29,6 +29,7 @@
     from .update_integration_runtime_request_py3 import UpdateIntegrationRuntimeRequest
     from .update_integration_runtime_node_request_py3 import UpdateIntegrationRuntimeNodeRequest
     from .linked_integration_runtime_request_py3 import LinkedIntegrationRuntimeRequest
+    from .create_linked_integration_runtime_request_py3 import CreateLinkedIntegrationRuntimeRequest
     from .parameter_specification_py3 import ParameterSpecification
     from .linked_service_py3 import LinkedService
     from .linked_service_resource_py3 import LinkedServiceResource
@@ -364,6 +365,7 @@
     from .update_integration_runtime_request import UpdateIntegrationRuntimeRequest
     from .update_integration_runtime_node_request import UpdateIntegrationRuntimeNodeRequest
     from .linked_integration_runtime_request import LinkedIntegrationRuntimeRequest
+    from .create_linked_integration_runtime_request import CreateLinkedIntegrationRuntimeRequest
     from .parameter_specification import ParameterSpecification
     from .linked_service import LinkedService
     from .linked_service_resource import LinkedServiceResource
@@ -767,6 +769,7 @@
     'UpdateIntegrationRuntimeRequest',
     'UpdateIntegrationRuntimeNodeRequest',
     'LinkedIntegrationRuntimeRequest',
+    'CreateLinkedIntegrationRuntimeRequest',
     'ParameterSpecification',
     'LinkedService',
     'LinkedServiceResource',

azure-mgmt-datafactory/azure/mgmt/datafactory/models/create_linked_integration_runtime_request.py

@@ -0,0 +1,43 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class CreateLinkedIntegrationRuntimeRequest(Model):
+    """The linked integration runtime information.
+
+    :param name: The name of the linked integration runtime.
+    :type name: str
+    :param subscription_id: The ID of the subscription that the linked
+     integration runtime belongs to.
+    :type subscription_id: str
+    :param data_factory_name: The name of the data factory that the linked
+     integration runtime belongs to.
+    :type data_factory_name: str
+    :param data_factory_location: The location of the data factory that the
+     linked integration runtime belongs to.
+    :type data_factory_location: str
+    """
+
+    _attribute_map = {
+        'name': {'key': 'name', 'type': 'str'},
+        'subscription_id': {'key': 'subscriptionId', 'type': 'str'},
+        'data_factory_name': {'key': 'dataFactoryName', 'type': 'str'},
+        'data_factory_location': {'key': 'dataFactoryLocation', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(CreateLinkedIntegrationRuntimeRequest, self).__init__(**kwargs)
+        self.name = kwargs.get('name', None)
+        self.subscription_id = kwargs.get('subscription_id', None)
+        self.data_factory_name = kwargs.get('data_factory_name', None)
+        self.data_factory_location = kwargs.get('data_factory_location', None)

azure-mgmt-datafactory/azure/mgmt/datafactory/models/create_linked_integration_runtime_request_py3.py

@@ -0,0 +1,43 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class CreateLinkedIntegrationRuntimeRequest(Model):
+    """The linked integration runtime information.
+
+    :param name: The name of the linked integration runtime.
+    :type name: str
+    :param subscription_id: The ID of the subscription that the linked
+     integration runtime belongs to.
+    :type subscription_id: str
+    :param data_factory_name: The name of the data factory that the linked
+     integration runtime belongs to.
+    :type data_factory_name: str
+    :param data_factory_location: The location of the data factory that the
+     linked integration runtime belongs to.
+    :type data_factory_location: str
+    """
+
+    _attribute_map = {
+        'name': {'key': 'name', 'type': 'str'},
+        'subscription_id': {'key': 'subscriptionId', 'type': 'str'},
+        'data_factory_name': {'key': 'dataFactoryName', 'type': 'str'},
+        'data_factory_location': {'key': 'dataFactoryLocation', 'type': 'str'},
+    }
+
+    def __init__(self, *, name: str=None, subscription_id: str=None, data_factory_name: str=None, data_factory_location: str=None, **kwargs) -> None:
+        super(CreateLinkedIntegrationRuntimeRequest, self).__init__(**kwargs)
+        self.name = name
+        self.subscription_id = subscription_id
+        self.data_factory_name = data_factory_name
+        self.data_factory_location = data_factory_location

azure-mgmt-datafactory/azure/mgmt/datafactory/models/data_factory_management_client_enums.py

@@ -402,6 +402,7 @@ class SelfHostedIntegrationRuntimeNodeStatus(str, Enum):
 
 class IntegrationRuntimeUpdateResult(str, Enum):
 
+    none = "None"
     succeed = "Succeed"
     fail = "Fail"
 

azure-mgmt-datafactory/azure/mgmt/datafactory/models/self_hosted_integration_runtime_node.py

@@ -53,7 +53,7 @@ class SelfHostedIntegrationRuntimeNode(Model):
     :ivar last_stop_time: The integration runtime node last stop time.
     :vartype last_stop_time: datetime
     :ivar last_update_result: The result of the last integration runtime node
-     update. Possible values include: 'Succeed', 'Fail'
+     update. Possible values include: 'None', 'Succeed', 'Fail'
     :vartype last_update_result: str or
      ~azure.mgmt.datafactory.models.IntegrationRuntimeUpdateResult
     :ivar last_start_update_time: The last time for the integration runtime

azure-mgmt-datafactory/azure/mgmt/datafactory/models/self_hosted_integration_runtime_node_py3.py

@@ -53,7 +53,7 @@ class SelfHostedIntegrationRuntimeNode(Model):
     :ivar last_stop_time: The integration runtime node last stop time.
     :vartype last_stop_time: datetime
     :ivar last_update_result: The result of the last integration runtime node
-     update. Possible values include: 'Succeed', 'Fail'
+     update. Possible values include: 'None', 'Succeed', 'Fail'
     :vartype last_update_result: str or
      ~azure.mgmt.datafactory.models.IntegrationRuntimeUpdateResult
     :ivar last_start_update_time: The last time for the integration runtime

azure-mgmt-datafactory/azure/mgmt/datafactory/models/self_hosted_integration_runtime_status.py

@@ -77,6 +77,9 @@ class SelfHostedIntegrationRuntimeStatus(IntegrationRuntimeStatus):
     :vartype pushed_version: str
     :ivar latest_version: The latest version on download center.
     :vartype latest_version: str
+    :ivar auto_update_eta: The estimated time when the self-hosted integration
+     runtime will be updated.
+    :vartype auto_update_eta: datetime
     """
 
     _validation = {
@@ -96,6 +99,7 @@ class SelfHostedIntegrationRuntimeStatus(IntegrationRuntimeStatus):
         'version_status': {'readonly': True},
         'pushed_version': {'readonly': True},
         'latest_version': {'readonly': True},
+        'auto_update_eta': {'readonly': True},
     }
 
     _attribute_map = {
@@ -118,6 +122,7 @@ class SelfHostedIntegrationRuntimeStatus(IntegrationRuntimeStatus):
         'links': {'key': 'typeProperties.links', 'type': '[LinkedIntegrationRuntime]'},
         'pushed_version': {'key': 'typeProperties.pushedVersion', 'type': 'str'},
         'latest_version': {'key': 'typeProperties.latestVersion', 'type': 'str'},
+        'auto_update_eta': {'key': 'typeProperties.autoUpdateETA', 'type': 'iso-8601'},
     }
 
     def __init__(self, **kwargs):
@@ -137,4 +142,5 @@ def __init__(self, **kwargs):
         self.links = kwargs.get('links', None)
         self.pushed_version = None
         self.latest_version = None
+        self.auto_update_eta = None
         self.type = 'SelfHosted'

azure-mgmt-datafactory/azure/mgmt/datafactory/models/self_hosted_integration_runtime_status_py3.py

@@ -77,6 +77,9 @@ class SelfHostedIntegrationRuntimeStatus(IntegrationRuntimeStatus):
     :vartype pushed_version: str
     :ivar latest_version: The latest version on download center.
     :vartype latest_version: str
+    :ivar auto_update_eta: The estimated time when the self-hosted integration
+     runtime will be updated.
+    :vartype auto_update_eta: datetime
     """
 
     _validation = {
@@ -96,6 +99,7 @@ class SelfHostedIntegrationRuntimeStatus(IntegrationRuntimeStatus):
         'version_status': {'readonly': True},
         'pushed_version': {'readonly': True},
         'latest_version': {'readonly': True},
+        'auto_update_eta': {'readonly': True},
     }
 
     _attribute_map = {
@@ -118,6 +122,7 @@ class SelfHostedIntegrationRuntimeStatus(IntegrationRuntimeStatus):
         'links': {'key': 'typeProperties.links', 'type': '[LinkedIntegrationRuntime]'},
         'pushed_version': {'key': 'typeProperties.pushedVersion', 'type': 'str'},
         'latest_version': {'key': 'typeProperties.latestVersion', 'type': 'str'},
+        'auto_update_eta': {'key': 'typeProperties.autoUpdateETA', 'type': 'iso-8601'},
     }
 
     def __init__(self, *, additional_properties=None, nodes=None, links=None, **kwargs) -> None:
@@ -137,4 +142,5 @@ def __init__(self, *, additional_properties=None, nodes=None, links=None, **kwar
         self.links = links
         self.pushed_version = None
         self.latest_version = None
+        self.auto_update_eta = None
         self.type = 'SelfHosted'

azure-mgmt-datafactory/azure/mgmt/datafactory/operations/activity_runs_operations.py

@@ -76,6 +76,7 @@ def query_by_pipeline_run(
 
         # Construct headers
         header_parameters = {}
+        header_parameters['Accept'] = 'application/json'
         header_parameters['Content-Type'] = 'application/json; charset=utf-8'
         if self.config.generate_client_request_id:
             header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
@@ -88,9 +89,8 @@ def query_by_pipeline_run(
         body_content = self._serialize.body(filter_parameters, 'RunFilterParameters')
 
         # Construct and send request
-        request = self._client.post(url, query_parameters)
-        response = self._client.send(
-            request, header_parameters, body_content, stream=False, **operation_config)
+        request = self._client.post(url, query_parameters, header_parameters, body_content)
+        response = self._client.send(request, stream=False, **operation_config)
 
         if response.status_code not in [200]:
             exp = CloudError(response)

azure-mgmt-datafactory/azure/mgmt/datafactory/operations/datasets_operations.py

@@ -77,7 +77,7 @@ def internal_paging(next_link=None, raw=False):
 
             # Construct headers
             header_parameters = {}
-            header_parameters['Content-Type'] = 'application/json; charset=utf-8'
+            header_parameters['Accept'] = 'application/json'
             if self.config.generate_client_request_id:
                 header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
             if custom_headers:
@@ -86,9 +86,8 @@ def internal_paging(next_link=None, raw=False):
                 header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str')
 
             # Construct and send request
-            request = self._client.get(url, query_parameters)
-            response = self._client.send(
-                request, header_parameters, stream=False, **operation_config)
+            request = self._client.get(url, query_parameters, header_parameters)
+            response = self._client.send(request, stream=False, **operation_config)
 
             if response.status_code not in [200]:
                 exp = CloudError(response)
@@ -152,6 +151,7 @@ def create_or_update(
 
         # Construct headers
         header_parameters = {}
+        header_parameters['Accept'] = 'application/json'
         header_parameters['Content-Type'] = 'application/json; charset=utf-8'
         if self.config.generate_client_request_id:
             header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
@@ -166,9 +166,8 @@ def create_or_update(
         body_content = self._serialize.body(dataset, 'DatasetResource')
 
         # Construct and send request
-        request = self._client.put(url, query_parameters)
-        response = self._client.send(
-            request, header_parameters, body_content, stream=False, **operation_config)
+        request = self._client.put(url, query_parameters, header_parameters, body_content)
+        response = self._client.send(request, stream=False, **operation_config)
 
         if response.status_code not in [200]:
             exp = CloudError(response)
@@ -227,7 +226,7 @@ def get(
 
         # Construct headers
         header_parameters = {}
-        header_parameters['Content-Type'] = 'application/json; charset=utf-8'
+        header_parameters['Accept'] = 'application/json'
         if self.config.generate_client_request_id:
             header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
         if custom_headers:
@@ -238,8 +237,8 @@ def get(
             header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str')
 
         # Construct and send request
-        request = self._client.get(url, query_parameters)
-        response = self._client.send(request, header_parameters, stream=False, **operation_config)
+        request = self._client.get(url, query_parameters, header_parameters)
+        response = self._client.send(request, stream=False, **operation_config)
 
         if response.status_code not in [200, 304]:
             exp = CloudError(response)
@@ -293,7 +292,6 @@ def delete(
 
         # Construct headers
         header_parameters = {}
-        header_parameters['Content-Type'] = 'application/json; charset=utf-8'
         if self.config.generate_client_request_id:
             header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
         if custom_headers:
@@ -302,8 +300,8 @@ def delete(
             header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str')
 
         # Construct and send request
-        request = self._client.delete(url, query_parameters)
-        response = self._client.send(request, header_parameters, stream=False, **operation_config)
+        request = self._client.delete(url, query_parameters, header_parameters)
+        response = self._client.send(request, stream=False, **operation_config)
 
         if response.status_code not in [200, 204]:
             exp = CloudError(response)