[AutoPR datafactory/resource-manager] [Data Factory]Add schema mapping for hierarchical data

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
@@ -58,7 +58,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.
@@ -97,7 +97,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 = '2017-09-01-preview'

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

@@ -18,6 +18,7 @@
     from .azure_key_vault_secret_reference_py3 import AzureKeyVaultSecretReference
     from .secret_base_py3 import SecretBase
     from .factory_identity_py3 import FactoryIdentity
+    from .factory_vsts_configuration_py3 import FactoryVSTSConfiguration
     from .factory_py3 import Factory
     from .integration_runtime_py3 import IntegrationRuntime
     from .integration_runtime_resource_py3 import IntegrationRuntimeResource
@@ -39,6 +40,7 @@
     from .trigger_resource_py3 import TriggerResource
     from .create_run_response_py3 import CreateRunResponse
     from .error_response_py3 import ErrorResponse, ErrorResponseException
+    from .factory_repo_update_py3 import FactoryRepoUpdate
     from .pipeline_reference_py3 import PipelineReference
     from .trigger_pipeline_reference_py3 import TriggerPipelineReference
     from .factory_update_parameters_py3 import FactoryUpdateParameters
@@ -58,6 +60,7 @@
     from .operation_service_specification_py3 import OperationServiceSpecification
     from .operation_py3 import Operation
     from .operation_list_response_py3 import OperationListResponse
+    from .responsys_linked_service_py3 import ResponsysLinkedService
     from .azure_databricks_linked_service_py3 import AzureDatabricksLinkedService
     from .azure_data_lake_analytics_linked_service_py3 import AzureDataLakeAnalyticsLinkedService
     from .hd_insight_on_demand_linked_service_py3 import HDInsightOnDemandLinkedService
@@ -131,6 +134,7 @@
     from .sql_server_linked_service_py3 import SqlServerLinkedService
     from .azure_sql_dw_linked_service_py3 import AzureSqlDWLinkedService
     from .azure_storage_linked_service_py3 import AzureStorageLinkedService
+    from .responsys_object_dataset_py3 import ResponsysObjectDataset
     from .salesforce_marketing_cloud_object_dataset_py3 import SalesforceMarketingCloudObjectDataset
     from .vertica_table_dataset_py3 import VerticaTableDataset
     from .netezza_table_dataset_py3 import NetezzaTableDataset
@@ -196,6 +200,7 @@
     from .amazon_s3_dataset_py3 import AmazonS3Dataset
     from .retry_policy_py3 import RetryPolicy
     from .tumbling_window_trigger_py3 import TumblingWindowTrigger
+    from .blob_events_trigger_py3 import BlobEventsTrigger
     from .blob_trigger_py3 import BlobTrigger
     from .recurrence_schedule_occurrence_py3 import RecurrenceScheduleOccurrence
     from .recurrence_schedule_py3 import RecurrenceSchedule
@@ -213,6 +218,7 @@
     from .web_activity_py3 import WebActivity
     from .redshift_unload_settings_py3 import RedshiftUnloadSettings
     from .amazon_redshift_source_py3 import AmazonRedshiftSource
+    from .responsys_source_py3 import ResponsysSource
     from .salesforce_marketing_cloud_source_py3 import SalesforceMarketingCloudSource
     from .vertica_source_py3 import VerticaSource
     from .netezza_source_py3 import NetezzaSource
@@ -339,6 +345,7 @@
     from .azure_key_vault_secret_reference import AzureKeyVaultSecretReference
     from .secret_base import SecretBase
     from .factory_identity import FactoryIdentity
+    from .factory_vsts_configuration import FactoryVSTSConfiguration
     from .factory import Factory
     from .integration_runtime import IntegrationRuntime
     from .integration_runtime_resource import IntegrationRuntimeResource
@@ -360,6 +367,7 @@
     from .trigger_resource import TriggerResource
     from .create_run_response import CreateRunResponse
     from .error_response import ErrorResponse, ErrorResponseException
+    from .factory_repo_update import FactoryRepoUpdate
     from .pipeline_reference import PipelineReference
     from .trigger_pipeline_reference import TriggerPipelineReference
     from .factory_update_parameters import FactoryUpdateParameters
@@ -379,6 +387,7 @@
     from .operation_service_specification import OperationServiceSpecification
     from .operation import Operation
     from .operation_list_response import OperationListResponse
+    from .responsys_linked_service import ResponsysLinkedService
     from .azure_databricks_linked_service import AzureDatabricksLinkedService
     from .azure_data_lake_analytics_linked_service import AzureDataLakeAnalyticsLinkedService
     from .hd_insight_on_demand_linked_service import HDInsightOnDemandLinkedService
@@ -452,6 +461,7 @@
     from .sql_server_linked_service import SqlServerLinkedService
     from .azure_sql_dw_linked_service import AzureSqlDWLinkedService
     from .azure_storage_linked_service import AzureStorageLinkedService
+    from .responsys_object_dataset import ResponsysObjectDataset
     from .salesforce_marketing_cloud_object_dataset import SalesforceMarketingCloudObjectDataset
     from .vertica_table_dataset import VerticaTableDataset
     from .netezza_table_dataset import NetezzaTableDataset
@@ -517,6 +527,7 @@
     from .amazon_s3_dataset import AmazonS3Dataset
     from .retry_policy import RetryPolicy
     from .tumbling_window_trigger import TumblingWindowTrigger
+    from .blob_events_trigger import BlobEventsTrigger
     from .blob_trigger import BlobTrigger
     from .recurrence_schedule_occurrence import RecurrenceScheduleOccurrence
     from .recurrence_schedule import RecurrenceSchedule
@@ -534,6 +545,7 @@
     from .web_activity import WebActivity
     from .redshift_unload_settings import RedshiftUnloadSettings
     from .amazon_redshift_source import AmazonRedshiftSource
+    from .responsys_source import ResponsysSource
     from .salesforce_marketing_cloud_source import SalesforceMarketingCloudSource
     from .vertica_source import VerticaSource
     from .netezza_source import NetezzaSource
@@ -694,6 +706,7 @@
     DatasetCompressionLevel,
     JsonFormatFilePattern,
     TumblingWindowFrequency,
+    BlobEventTypes,
     DayOfWeek,
     DaysOfWeek,
     RecurrenceFrequency,
@@ -728,6 +741,7 @@
     'AzureKeyVaultSecretReference',
     'SecretBase',
     'FactoryIdentity',
+    'FactoryVSTSConfiguration',
     'Factory',
     'IntegrationRuntime',
     'IntegrationRuntimeResource',
@@ -749,6 +763,7 @@
     'TriggerResource',
     'CreateRunResponse',
     'ErrorResponse', 'ErrorResponseException',
+    'FactoryRepoUpdate',
     'PipelineReference',
     'TriggerPipelineReference',
     'FactoryUpdateParameters',
@@ -768,6 +783,7 @@
     'OperationServiceSpecification',
     'Operation',
     'OperationListResponse',
+    'ResponsysLinkedService',
     'AzureDatabricksLinkedService',
     'AzureDataLakeAnalyticsLinkedService',
     'HDInsightOnDemandLinkedService',
@@ -841,6 +857,7 @@
     'SqlServerLinkedService',
     'AzureSqlDWLinkedService',
     'AzureStorageLinkedService',
+    'ResponsysObjectDataset',
     'SalesforceMarketingCloudObjectDataset',
     'VerticaTableDataset',
     'NetezzaTableDataset',
@@ -906,6 +923,7 @@
     'AmazonS3Dataset',
     'RetryPolicy',
     'TumblingWindowTrigger',
+    'BlobEventsTrigger',
     'BlobTrigger',
     'RecurrenceScheduleOccurrence',
     'RecurrenceSchedule',
@@ -923,6 +941,7 @@
     'WebActivity',
     'RedshiftUnloadSettings',
     'AmazonRedshiftSource',
+    'ResponsysSource',
     'SalesforceMarketingCloudSource',
     'VerticaSource',
     'NetezzaSource',
@@ -1082,6 +1101,7 @@
     'DatasetCompressionLevel',
     'JsonFormatFilePattern',
     'TumblingWindowFrequency',
+    'BlobEventTypes',
     'DayOfWeek',
     'DaysOfWeek',
     'RecurrenceFrequency',

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AmazonMWSLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .dataset import Dataset
+from .dataset_py3 import Dataset
 
 
 class AmazonMWSObjectDataset(Dataset):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .copy_source import CopySource
+from .copy_source_py3 import CopySource
 
 
 class AmazonMWSSource(CopySource):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AmazonRedshiftLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .copy_source import CopySource
+from .copy_source_py3 import CopySource
 
 
 class AmazonRedshiftSource(CopySource):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .dataset import Dataset
+from .dataset_py3 import Dataset
 
 
 class AmazonS3Dataset(Dataset):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AmazonS3LinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .dataset_storage_format import DatasetStorageFormat
+from .dataset_storage_format_py3 import DatasetStorageFormat
 
 
 class AvroFormat(DatasetStorageFormat):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AzureBatchLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .dataset import Dataset
+from .dataset_py3 import Dataset
 
 
 class AzureBlobDataset(Dataset):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AzureDataLakeAnalyticsLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .dataset import Dataset
+from .dataset_py3 import Dataset
 
 
 class AzureDataLakeStoreDataset(Dataset):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AzureDataLakeStoreLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .copy_sink import CopySink
+from .copy_sink_py3 import CopySink
 
 
 class AzureDataLakeStoreSink(CopySink):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .copy_source import CopySource
+from .copy_source_py3 import CopySource
 
 
 class AzureDataLakeStoreSource(CopySource):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AzureDatabricksLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AzureKeyVaultLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .secret_base import SecretBase
+from .secret_base_py3 import SecretBase
 
 
 class AzureKeyVaultSecretReference(SecretBase):
@@ -44,7 +44,7 @@ class AzureKeyVaultSecretReference(SecretBase):
     }
 
     def __init__(self, *, store, secret_name, secret_version=None, **kwargs) -> None:
-        super(AzureKeyVaultSecretReference, self).__init__(, **kwargs)
+        super(AzureKeyVaultSecretReference, self).__init__(**kwargs)
         self.store = store
         self.secret_name = secret_name
         self.secret_version = secret_version

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .execution_activity import ExecutionActivity
+from .execution_activity_py3 import ExecutionActivity
 
 
 class AzureMLBatchExecutionActivity(ExecutionActivity):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .linked_service import LinkedService
+from .linked_service_py3 import LinkedService
 
 
 class AzureMLLinkedService(LinkedService):

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

@@ -9,7 +9,7 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-from .execution_activity import ExecutionActivity
+from .execution_activity_py3 import ExecutionActivity
 
 
 class AzureMLUpdateResourceActivity(ExecutionActivity):