Generated from 2e36516bed7132327c0e1664747aa438ad744797 (#2292)

[ADF] Swagger Change for Responsys Source

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

@@ -18,16 +18,18 @@ 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 type: Constant filled by server.
+    :param type: Required. Constant filled by server.
     :type type: str
     """
 
@@ -48,10 +50,10 @@ class Activity(Model):
         'type': {'Execution': 'ExecutionActivity', 'Container': 'ControlActivity'}
     }
 
-    def __init__(self, name, additional_properties=None, description=None, depends_on=None):
-        super(Activity, self).__init__()
-        self.additional_properties = additional_properties
-        self.name = name
-        self.description = description
-        self.depends_on = depends_on
+    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.type = None

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)

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

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

@@ -45,10 +45,10 @@ 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_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_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_output = kwargs.get('secure_output', None)

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

@@ -0,0 +1,54 @@
+# 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_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_output': {'key': 'secureOutput', 'type': 'bool'},
+    }
+
+    def __init__(self, *, additional_properties=None, timeout=None, retry=None, retry_interval_in_seconds: int=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_output = secure_output

azure-mgmt-datafactory/azure/mgmt/datafactory/models/activity_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 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 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]'},
+        '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, **kwargs) -> None:
+        super(Activity, self).__init__(**kwargs)
+        self.additional_properties = additional_properties
+        self.name = name
+        self.description = description
+        self.depends_on = depends_on
+        self.type = None

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

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

@@ -0,0 +1,102 @@
+# 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 ActivityRun(Model):
+    """Information about an activity run in a pipeline.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    :param additional_properties: Unmatched properties from the message are
+     deserialized this collection
+    :type additional_properties: dict[str, object]
+    :ivar pipeline_name: The name of the pipeline.
+    :vartype pipeline_name: str
+    :ivar pipeline_run_id: The id of the pipeline run.
+    :vartype pipeline_run_id: str
+    :ivar activity_name: The name of the activity.
+    :vartype activity_name: str
+    :ivar activity_type: The type of the activity.
+    :vartype activity_type: str
+    :ivar activity_run_id: The id of the activity run.
+    :vartype activity_run_id: str
+    :ivar linked_service_name: The name of the compute linked service.
+    :vartype linked_service_name: str
+    :ivar status: The status of the activity run.
+    :vartype status: str
+    :ivar activity_run_start: The start time of the activity run in 'ISO 8601'
+     format.
+    :vartype activity_run_start: datetime
+    :ivar activity_run_end: The end time of the activity run in 'ISO 8601'
+     format.
+    :vartype activity_run_end: datetime
+    :ivar duration_in_ms: The duration of the activity run.
+    :vartype duration_in_ms: int
+    :ivar input: The input for the activity.
+    :vartype input: object
+    :ivar output: The output for the activity.
+    :vartype output: object
+    :ivar error: The error if any from the activity run.
+    :vartype error: object
+    """
+
+    _validation = {
+        'pipeline_name': {'readonly': True},
+        'pipeline_run_id': {'readonly': True},
+        'activity_name': {'readonly': True},
+        'activity_type': {'readonly': True},
+        'activity_run_id': {'readonly': True},
+        'linked_service_name': {'readonly': True},
+        'status': {'readonly': True},
+        'activity_run_start': {'readonly': True},
+        'activity_run_end': {'readonly': True},
+        'duration_in_ms': {'readonly': True},
+        'input': {'readonly': True},
+        'output': {'readonly': True},
+        'error': {'readonly': True},
+    }
+
+    _attribute_map = {
+        'additional_properties': {'key': '', 'type': '{object}'},
+        'pipeline_name': {'key': 'pipelineName', 'type': 'str'},
+        'pipeline_run_id': {'key': 'pipelineRunId', 'type': 'str'},
+        'activity_name': {'key': 'activityName', 'type': 'str'},
+        'activity_type': {'key': 'activityType', 'type': 'str'},
+        'activity_run_id': {'key': 'activityRunId', 'type': 'str'},
+        'linked_service_name': {'key': 'linkedServiceName', 'type': 'str'},
+        'status': {'key': 'status', 'type': 'str'},
+        'activity_run_start': {'key': 'activityRunStart', 'type': 'iso-8601'},
+        'activity_run_end': {'key': 'activityRunEnd', 'type': 'iso-8601'},
+        'duration_in_ms': {'key': 'durationInMs', 'type': 'int'},
+        'input': {'key': 'input', 'type': 'object'},
+        'output': {'key': 'output', 'type': 'object'},
+        'error': {'key': 'error', 'type': 'object'},
+    }
+
+    def __init__(self, *, additional_properties=None, **kwargs) -> None:
+        super(ActivityRun, self).__init__(**kwargs)
+        self.additional_properties = additional_properties
+        self.pipeline_name = None
+        self.pipeline_run_id = None
+        self.activity_name = None
+        self.activity_type = None
+        self.activity_run_id = None
+        self.linked_service_name = None
+        self.status = None
+        self.activity_run_start = None
+        self.activity_run_end = None
+        self.duration_in_ms = None
+        self.input = None
+        self.output = None
+        self.error = None