From d25811de057c6c4a8e9ef16ab6467b1a8a18d9a9 Mon Sep 17 00:00:00 2001 From: SDK Automation Date: Wed, 29 Jul 2020 06:06:22 +0000 Subject: [PATCH] Generated from 284f696f9afa6c4f80e9efab308e2330247efeac Support source/sink level staging in dataflow --- .../azure/mgmt/datafactory/models/_models.py | 8 ++++++++ .../azure/mgmt/datafactory/models/_models_py3.py | 12 ++++++++++-- 2 files changed, 18 insertions(+), 2 deletions(-) diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models.py index 146a5589d83c..91660cf75d90 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models.py @@ -9950,6 +9950,8 @@ class DataFlowSink(Transformation): :param schema_linked_service: Schema linked service reference. :type schema_linked_service: ~azure.mgmt.datafactory.models.LinkedServiceReference + :param staging: Staging info for execute data flow activity. + :type staging: ~azure.mgmt.datafactory.models.DataFlowStagingInfo """ _validation = { @@ -9962,6 +9964,7 @@ class DataFlowSink(Transformation): 'dataset': {'key': 'dataset', 'type': 'DatasetReference'}, 'linked_service': {'key': 'linkedService', 'type': 'LinkedServiceReference'}, 'schema_linked_service': {'key': 'schemaLinkedService', 'type': 'LinkedServiceReference'}, + 'staging': {'key': 'staging', 'type': 'DataFlowStagingInfo'}, } def __init__(self, **kwargs): @@ -9969,6 +9972,7 @@ def __init__(self, **kwargs): self.dataset = kwargs.get('dataset', None) self.linked_service = kwargs.get('linked_service', None) self.schema_linked_service = kwargs.get('schema_linked_service', None) + self.staging = kwargs.get('staging', None) class DataFlowSource(Transformation): @@ -9988,6 +9992,8 @@ class DataFlowSource(Transformation): :param schema_linked_service: Schema linked service reference. :type schema_linked_service: ~azure.mgmt.datafactory.models.LinkedServiceReference + :param staging: Staging info for execute data flow activity. + :type staging: ~azure.mgmt.datafactory.models.DataFlowStagingInfo """ _validation = { @@ -10000,6 +10006,7 @@ class DataFlowSource(Transformation): 'dataset': {'key': 'dataset', 'type': 'DatasetReference'}, 'linked_service': {'key': 'linkedService', 'type': 'LinkedServiceReference'}, 'schema_linked_service': {'key': 'schemaLinkedService', 'type': 'LinkedServiceReference'}, + 'staging': {'key': 'staging', 'type': 'DataFlowStagingInfo'}, } def __init__(self, **kwargs): @@ -10007,6 +10014,7 @@ def __init__(self, **kwargs): self.dataset = kwargs.get('dataset', None) self.linked_service = kwargs.get('linked_service', None) self.schema_linked_service = kwargs.get('schema_linked_service', None) + self.staging = kwargs.get('staging', None) class DataFlowSourceSetting(Model): diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py index c3b41e3fa089..37edb566690b 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py @@ -9950,6 +9950,8 @@ class DataFlowSink(Transformation): :param schema_linked_service: Schema linked service reference. :type schema_linked_service: ~azure.mgmt.datafactory.models.LinkedServiceReference + :param staging: Staging info for execute data flow activity. + :type staging: ~azure.mgmt.datafactory.models.DataFlowStagingInfo """ _validation = { @@ -9962,13 +9964,15 @@ class DataFlowSink(Transformation): 'dataset': {'key': 'dataset', 'type': 'DatasetReference'}, 'linked_service': {'key': 'linkedService', 'type': 'LinkedServiceReference'}, 'schema_linked_service': {'key': 'schemaLinkedService', 'type': 'LinkedServiceReference'}, + 'staging': {'key': 'staging', 'type': 'DataFlowStagingInfo'}, } - def __init__(self, *, name: str, description: str=None, dataset=None, linked_service=None, schema_linked_service=None, **kwargs) -> None: + def __init__(self, *, name: str, description: str=None, dataset=None, linked_service=None, schema_linked_service=None, staging=None, **kwargs) -> None: super(DataFlowSink, self).__init__(name=name, description=description, **kwargs) self.dataset = dataset self.linked_service = linked_service self.schema_linked_service = schema_linked_service + self.staging = staging class DataFlowSource(Transformation): @@ -9988,6 +9992,8 @@ class DataFlowSource(Transformation): :param schema_linked_service: Schema linked service reference. :type schema_linked_service: ~azure.mgmt.datafactory.models.LinkedServiceReference + :param staging: Staging info for execute data flow activity. + :type staging: ~azure.mgmt.datafactory.models.DataFlowStagingInfo """ _validation = { @@ -10000,13 +10006,15 @@ class DataFlowSource(Transformation): 'dataset': {'key': 'dataset', 'type': 'DatasetReference'}, 'linked_service': {'key': 'linkedService', 'type': 'LinkedServiceReference'}, 'schema_linked_service': {'key': 'schemaLinkedService', 'type': 'LinkedServiceReference'}, + 'staging': {'key': 'staging', 'type': 'DataFlowStagingInfo'}, } - def __init__(self, *, name: str, description: str=None, dataset=None, linked_service=None, schema_linked_service=None, **kwargs) -> None: + def __init__(self, *, name: str, description: str=None, dataset=None, linked_service=None, schema_linked_service=None, staging=None, **kwargs) -> None: super(DataFlowSource, self).__init__(name=name, description=description, **kwargs) self.dataset = dataset self.linked_service = linked_service self.schema_linked_service = schema_linked_service + self.staging = staging class DataFlowSourceSetting(Model):