v3.0.52

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from msrest.service_client import ServiceClient
+from msrest.service_client import SDKClient
 from msrest import Serializer, Deserializer
 from msrestazure import AzureConfiguration
 from .version import VERSION
@@ -62,7 +62,7 @@ def __init__(
         self.subscription_id = subscription_id
 
 
-class DataFactoryManagementClient(object):
+class DataFactoryManagementClient(SDKClient):
     """The Azure Data Factory V2 management API provides a RESTful set of web services that interact with Azure Data Factory V2 services.
 
     :ivar config: Configuration for client.
@@ -109,7 +109,7 @@ def __init__(
             self, credentials, subscription_id, base_url=None):
 
         self.config = DataFactoryManagementClientConfiguration(credentials, subscription_id, base_url)
-        self._client = ServiceClient(self.config.credentials, self.config)
+        super(DataFactoryManagementClient, self).__init__(self.config.credentials, self.config)
 
         client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
         self.api_version = '2018-06-01'

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

@@ -29,8 +29,8 @@ class AccessPolicyResponse(Model):
         'data_plane_url': {'key': 'dataPlaneUrl', 'type': 'str'},
     }
 
-    def __init__(self, policy=None, access_token=None, data_plane_url=None):
-        super(AccessPolicyResponse, self).__init__()
-        self.policy = policy
-        self.access_token = access_token
-        self.data_plane_url = data_plane_url
+    def __init__(self, **kwargs):
+        super(AccessPolicyResponse, self).__init__(**kwargs)
+        self.policy = kwargs.get('policy', None)
+        self.access_token = kwargs.get('access_token', None)
+        self.data_plane_url = kwargs.get('data_plane_url', None)

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

@@ -0,0 +1,36 @@
+# 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 AccessPolicyResponse(Model):
+    """Get Data Plane read only token response definition.
+
+    :param policy: The user access policy.
+    :type policy: ~azure.mgmt.datafactory.models.UserAccessPolicy
+    :param access_token: Data Plane read only access token.
+    :type access_token: str
+    :param data_plane_url: Data Plane service base URL.
+    :type data_plane_url: str
+    """
+
+    _attribute_map = {
+        'policy': {'key': 'policy', 'type': 'UserAccessPolicy'},
+        'access_token': {'key': 'accessToken', 'type': 'str'},
+        'data_plane_url': {'key': 'dataPlaneUrl', 'type': 'str'},
+    }
+
+    def __init__(self, *, policy=None, access_token: str=None, data_plane_url: str=None, **kwargs) -> None:
+        super(AccessPolicyResponse, self).__init__(**kwargs)
+        self.policy = policy
+        self.access_token = access_token
+        self.data_plane_url = data_plane_url

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

@@ -18,18 +18,20 @@ class Activity(Model):
     You probably want to use the sub-classes and not this class directly. Known
     sub-classes are: ExecutionActivity, ControlActivity
 
+    All required parameters must be populated in order to send to Azure.
+
     :param additional_properties: Unmatched properties from the message are
      deserialized this collection
     :type additional_properties: dict[str, object]
-    :param name: Activity name.
+    :param name: Required. Activity name.
     :type name: str
     :param description: Activity description.
     :type description: str
     :param depends_on: Activity depends on condition.
     :type depends_on: list[~azure.mgmt.datafactory.models.ActivityDependency]
     :param user_properties: Activity user properties.
     :type user_properties: list[~azure.mgmt.datafactory.models.UserProperty]
-    :param type: Constant filled by server.
+    :param type: Required. Constant filled by server.
     :type type: str
     """
 
@@ -51,11 +53,11 @@ class Activity(Model):
         'type': {'Execution': 'ExecutionActivity', 'Container': 'ControlActivity'}
     }
 
-    def __init__(self, name, additional_properties=None, description=None, depends_on=None, user_properties=None):
-        super(Activity, self).__init__()
-        self.additional_properties = additional_properties
-        self.name = name
-        self.description = description
-        self.depends_on = depends_on
-        self.user_properties = user_properties
+    def __init__(self, **kwargs):
+        super(Activity, self).__init__(**kwargs)
+        self.additional_properties = kwargs.get('additional_properties', None)
+        self.name = kwargs.get('name', None)
+        self.description = kwargs.get('description', None)
+        self.depends_on = kwargs.get('depends_on', None)
+        self.user_properties = kwargs.get('user_properties', None)
         self.type = None

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

@@ -15,12 +15,15 @@
 class ActivityDependency(Model):
     """Activity dependency information.
 
+    All required parameters must be populated in order to send to Azure.
+
     :param additional_properties: Unmatched properties from the message are
      deserialized this collection
     :type additional_properties: dict[str, object]
-    :param activity: Activity name.
+    :param activity: Required. Activity name.
     :type activity: str
-    :param dependency_conditions: Match-Condition for the dependency.
+    :param dependency_conditions: Required. Match-Condition for the
+     dependency.
     :type dependency_conditions: list[str or
      ~azure.mgmt.datafactory.models.DependencyCondition]
     """
@@ -36,8 +39,8 @@ class ActivityDependency(Model):
         'dependency_conditions': {'key': 'dependencyConditions', 'type': '[str]'},
     }
 
-    def __init__(self, activity, dependency_conditions, additional_properties=None):
-        super(ActivityDependency, self).__init__()
-        self.additional_properties = additional_properties
-        self.activity = activity
-        self.dependency_conditions = dependency_conditions
+    def __init__(self, **kwargs):
+        super(ActivityDependency, self).__init__(**kwargs)
+        self.additional_properties = kwargs.get('additional_properties', None)
+        self.activity = kwargs.get('activity', None)
+        self.dependency_conditions = kwargs.get('dependency_conditions', None)

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

@@ -0,0 +1,46 @@
+# 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 ActivityDependency(Model):
+    """Activity dependency information.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param additional_properties: Unmatched properties from the message are
+     deserialized this collection
+    :type additional_properties: dict[str, object]
+    :param activity: Required. Activity name.
+    :type activity: str
+    :param dependency_conditions: Required. Match-Condition for the
+     dependency.
+    :type dependency_conditions: list[str or
+     ~azure.mgmt.datafactory.models.DependencyCondition]
+    """
+
+    _validation = {
+        'activity': {'required': True},
+        'dependency_conditions': {'required': True},
+    }
+
+    _attribute_map = {
+        'additional_properties': {'key': '', 'type': '{object}'},
+        'activity': {'key': 'activity', 'type': 'str'},
+        'dependency_conditions': {'key': 'dependencyConditions', 'type': '[str]'},
+    }
+
+    def __init__(self, *, activity: str, dependency_conditions, additional_properties=None, **kwargs) -> None:
+        super(ActivityDependency, self).__init__(**kwargs)
+        self.additional_properties = additional_properties
+        self.activity = activity
+        self.dependency_conditions = dependency_conditions

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

@@ -49,11 +49,11 @@ class ActivityPolicy(Model):
         'secure_output': {'key': 'secureOutput', 'type': 'bool'},
     }
 
-    def __init__(self, additional_properties=None, timeout=None, retry=None, retry_interval_in_seconds=None, secure_input=None, secure_output=None):
-        super(ActivityPolicy, self).__init__()
-        self.additional_properties = additional_properties
-        self.timeout = timeout
-        self.retry = retry
-        self.retry_interval_in_seconds = retry_interval_in_seconds
-        self.secure_input = secure_input
-        self.secure_output = secure_output
+    def __init__(self, **kwargs):
+        super(ActivityPolicy, self).__init__(**kwargs)
+        self.additional_properties = kwargs.get('additional_properties', None)
+        self.timeout = kwargs.get('timeout', None)
+        self.retry = kwargs.get('retry', None)
+        self.retry_interval_in_seconds = kwargs.get('retry_interval_in_seconds', None)
+        self.secure_input = kwargs.get('secure_input', None)
+        self.secure_output = kwargs.get('secure_output', None)

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

@@ -0,0 +1,59 @@
+# 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 ActivityPolicy(Model):
+    """Execution policy for an activity.
+
+    :param additional_properties: Unmatched properties from the message are
+     deserialized this collection
+    :type additional_properties: dict[str, object]
+    :param timeout: Specifies the timeout for the activity to run. The default
+     timeout is 7 days. Type: string (or Expression with resultType string),
+     pattern: ((\\d+)\\.)?(\\d\\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+    :type timeout: object
+    :param retry: Maximum ordinary retry attempts. Default is 0. Type: integer
+     (or Expression with resultType integer), minimum: 0.
+    :type retry: object
+    :param retry_interval_in_seconds: Interval between each retry attempt (in
+     seconds). The default is 30 sec.
+    :type retry_interval_in_seconds: int
+    :param secure_input: When set to true, Input from activity is considered
+     as secure and will not be logged to monitoring.
+    :type secure_input: bool
+    :param secure_output: When set to true, Output from activity is considered
+     as secure and will not be logged to monitoring.
+    :type secure_output: bool
+    """
+
+    _validation = {
+        'retry_interval_in_seconds': {'maximum': 86400, 'minimum': 30},
+    }
+
+    _attribute_map = {
+        'additional_properties': {'key': '', 'type': '{object}'},
+        'timeout': {'key': 'timeout', 'type': 'object'},
+        'retry': {'key': 'retry', 'type': 'object'},
+        'retry_interval_in_seconds': {'key': 'retryIntervalInSeconds', 'type': 'int'},
+        'secure_input': {'key': 'secureInput', 'type': 'bool'},
+        'secure_output': {'key': 'secureOutput', 'type': 'bool'},
+    }
+
+    def __init__(self, *, additional_properties=None, timeout=None, retry=None, retry_interval_in_seconds: int=None, secure_input: bool=None, secure_output: bool=None, **kwargs) -> None:
+        super(ActivityPolicy, self).__init__(**kwargs)
+        self.additional_properties = additional_properties
+        self.timeout = timeout
+        self.retry = retry
+        self.retry_interval_in_seconds = retry_interval_in_seconds
+        self.secure_input = secure_input
+        self.secure_output = secure_output

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

@@ -0,0 +1,63 @@
+# 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 Activity(Model):
+    """A pipeline activity.
+
+    You probably want to use the sub-classes and not this class directly. Known
+    sub-classes are: ExecutionActivity, ControlActivity
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param additional_properties: Unmatched properties from the message are
+     deserialized this collection
+    :type additional_properties: dict[str, object]
+    :param name: Required. Activity name.
+    :type name: str
+    :param description: Activity description.
+    :type description: str
+    :param depends_on: Activity depends on condition.
+    :type depends_on: list[~azure.mgmt.datafactory.models.ActivityDependency]
+    :param user_properties: Activity user properties.
+    :type user_properties: list[~azure.mgmt.datafactory.models.UserProperty]
+    :param type: Required. Constant filled by server.
+    :type type: str
+    """
+
+    _validation = {
+        'name': {'required': True},
+        'type': {'required': True},
+    }
+
+    _attribute_map = {
+        'additional_properties': {'key': '', 'type': '{object}'},
+        'name': {'key': 'name', 'type': 'str'},
+        'description': {'key': 'description', 'type': 'str'},
+        'depends_on': {'key': 'dependsOn', 'type': '[ActivityDependency]'},
+        'user_properties': {'key': 'userProperties', 'type': '[UserProperty]'},
+        'type': {'key': 'type', 'type': 'str'},
+    }
+
+    _subtype_map = {
+        'type': {'Execution': 'ExecutionActivity', 'Container': 'ControlActivity'}
+    }
+
+    def __init__(self, *, name: str, additional_properties=None, description: str=None, depends_on=None, user_properties=None, **kwargs) -> None:
+        super(Activity, self).__init__(**kwargs)
+        self.additional_properties = additional_properties
+        self.name = name
+        self.description = description
+        self.depends_on = depends_on
+        self.user_properties = user_properties
+        self.type = None

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

@@ -84,9 +84,9 @@ class ActivityRun(Model):
         'error': {'key': 'error', 'type': 'object'},
     }
 
-    def __init__(self, additional_properties=None):
-        super(ActivityRun, self).__init__()
-        self.additional_properties = additional_properties
+    def __init__(self, **kwargs):
+        super(ActivityRun, self).__init__(**kwargs)
+        self.additional_properties = kwargs.get('additional_properties', None)
         self.pipeline_name = None
         self.pipeline_run_id = None
         self.activity_name = None