Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -23,6 +23,8 @@
from .operations.pipeline_runs_operations import PipelineRunsOperations
from .operations.activity_runs_operations import ActivityRunsOperations
from .operations.triggers_operations import TriggersOperations
from .operations.rerun_triggers_operations import RerunTriggersOperations
from .operations.trigger_runs_operations import TriggerRunsOperations
from . import models


Expand Down Expand Up @@ -58,7 +60,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.
Expand All @@ -84,6 +86,10 @@ class DataFactoryManagementClient(object):
:vartype activity_runs: azure.mgmt.datafactory.operations.ActivityRunsOperations
:ivar triggers: Triggers operations
:vartype triggers: azure.mgmt.datafactory.operations.TriggersOperations
:ivar rerun_triggers: RerunTriggers operations
:vartype rerun_triggers: azure.mgmt.datafactory.operations.RerunTriggersOperations
:ivar trigger_runs: TriggerRuns operations
:vartype trigger_runs: azure.mgmt.datafactory.operations.TriggerRunsOperations

:param credentials: Credentials needed for the client to connect to Azure.
:type credentials: :mod:`A msrestazure Credentials
Expand All @@ -97,10 +103,10 @@ 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 = '2017-09-01-preview'
self.api_version = '2018-06-01'
self._serialize = Serializer(client_models)
self._deserialize = Deserializer(client_models)

Expand All @@ -124,3 +130,7 @@ def __init__(
self._client, self.config, self._serialize, self._deserialize)
self.triggers = TriggersOperations(
self._client, self.config, self._serialize, self._deserialize)
self.rerun_triggers = RerunTriggersOperations(
self._client, self.config, self._serialize, self._deserialize)
self.trigger_runs = TriggerRunsOperations(
self._client, self.config, self._serialize, self._deserialize)
1,135 changes: 779 additions & 356 deletions azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py

Large diffs are not rendered by default.

22 changes: 14 additions & 8 deletions azure-mgmt-datafactory/azure/mgmt/datafactory/models/activity.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,16 +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 type: Constant filled by server.
: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
"""

Expand All @@ -41,17 +45,19 @@ class Activity(Model):
'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, 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.user_properties = kwargs.get('user_properties', None)
self.type = None
Original file line number Diff line number Diff line change
Expand Up @@ -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]
"""
Expand All @@ -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)
Original file line number Diff line number Diff line change
@@ -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
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,9 @@ class ActivityPolicy(Model):
: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
Expand All @@ -42,13 +45,15 @@ class ActivityPolicy(Model):
'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=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_input = kwargs.get('secure_input', None)
self.secure_output = kwargs.get('secure_output', None)
Original file line number Diff line number Diff line change
@@ -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
Original file line number Diff line number Diff line change
@@ -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
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Loading