[AutoPR datafactory/resource-manager] [Datafactory] Support create pipeline run with recovery mode

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

@@ -95,6 +95,10 @@
     from .schedule_trigger_py3 import ScheduleTrigger
     from .multiple_pipeline_trigger_py3 import MultiplePipelineTrigger
     from .azure_function_linked_service_py3 import AzureFunctionLinkedService
+    from .azure_data_explorer_linked_service_py3 import AzureDataExplorerLinkedService
+    from .google_ad_words_linked_service_py3 import GoogleAdWordsLinkedService
+    from .oracle_service_cloud_linked_service_py3 import OracleServiceCloudLinkedService
+    from .dynamics_ax_linked_service_py3 import DynamicsAXLinkedService
     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
@@ -143,7 +147,11 @@
     from .sap_ecc_linked_service_py3 import SapEccLinkedService
     from .sap_cloud_for_customer_linked_service_py3 import SapCloudForCustomerLinkedService
     from .salesforce_linked_service_py3 import SalesforceLinkedService
+    from .office365_linked_service_py3 import Office365LinkedService
+    from .azure_blob_fs_linked_service_py3 import AzureBlobFSLinkedService
     from .azure_data_lake_store_linked_service_py3 import AzureDataLakeStoreLinkedService
+    from .cosmos_db_mongo_db_api_linked_service_py3 import CosmosDbMongoDbApiLinkedService
+    from .mongo_db_v2_linked_service_py3 import MongoDbV2LinkedService
     from .mongo_db_linked_service_py3 import MongoDbLinkedService
     from .cassandra_linked_service_py3 import CassandraLinkedService
     from .web_client_certificate_authentication_py3 import WebClientCertificateAuthentication
@@ -174,6 +182,10 @@
     from .azure_table_storage_linked_service_py3 import AzureTableStorageLinkedService
     from .azure_blob_storage_linked_service_py3 import AzureBlobStorageLinkedService
     from .azure_storage_linked_service_py3 import AzureStorageLinkedService
+    from .google_ad_words_object_dataset_py3 import GoogleAdWordsObjectDataset
+    from .azure_data_explorer_table_dataset_py3 import AzureDataExplorerTableDataset
+    from .oracle_service_cloud_object_dataset_py3 import OracleServiceCloudObjectDataset
+    from .dynamics_ax_resource_dataset_py3 import DynamicsAXResourceDataset
     from .responsys_object_dataset_py3 import ResponsysObjectDataset
     from .salesforce_marketing_cloud_object_dataset_py3 import SalesforceMarketingCloudObjectDataset
     from .vertica_table_dataset_py3 import VerticaTableDataset
@@ -228,8 +240,13 @@
     from .azure_my_sql_table_dataset_py3 import AzureMySqlTableDataset
     from .oracle_table_dataset_py3 import OracleTableDataset
     from .odata_resource_dataset_py3 import ODataResourceDataset
+    from .cosmos_db_mongo_db_api_collection_dataset_py3 import CosmosDbMongoDbApiCollectionDataset
+    from .mongo_db_v2_collection_dataset_py3 import MongoDbV2CollectionDataset
     from .mongo_db_collection_dataset_py3 import MongoDbCollectionDataset
     from .file_share_dataset_py3 import FileShareDataset
+    from .azure_data_lake_store_cosmos_structured_stream_dataset_py3 import AzureDataLakeStoreCosmosStructuredStreamDataset
+    from .office365_dataset_py3 import Office365Dataset
+    from .azure_blob_fs_dataset_py3 import AzureBlobFSDataset
     from .azure_data_lake_store_dataset_py3 import AzureDataLakeStoreDataset
     from .dynamics_entity_dataset_py3 import DynamicsEntityDataset
     from .document_db_collection_dataset_py3 import DocumentDbCollectionDataset
@@ -254,6 +271,9 @@
     from .web_activity_py3 import WebActivity
     from .redshift_unload_settings_py3 import RedshiftUnloadSettings
     from .amazon_redshift_source_py3 import AmazonRedshiftSource
+    from .google_ad_words_source_py3 import GoogleAdWordsSource
+    from .oracle_service_cloud_source_py3 import OracleServiceCloudSource
+    from .dynamics_ax_source_py3 import DynamicsAXSource
     from .responsys_source_py3 import ResponsysSource
     from .salesforce_marketing_cloud_source_py3 import SalesforceMarketingCloudSource
     from .vertica_source_py3 import VerticaSource
@@ -285,11 +305,17 @@
     from .azure_postgre_sql_source_py3 import AzurePostgreSqlSource
     from .amazon_mws_source_py3 import AmazonMWSSource
     from .http_source_py3 import HttpSource
+    from .azure_blob_fs_source_py3 import AzureBlobFSSource
     from .azure_data_lake_store_source_py3 import AzureDataLakeStoreSource
+    from .office365_source_py3 import Office365Source
+    from .mongo_db_cursor_methods_properties_py3 import MongoDbCursorMethodsProperties
+    from .cosmos_db_mongo_db_api_source_py3 import CosmosDbMongoDbApiSource
+    from .mongo_db_v2_source_py3 import MongoDbV2Source
     from .mongo_db_source_py3 import MongoDbSource
     from .cassandra_source_py3 import CassandraSource
     from .web_source_py3 import WebSource
     from .oracle_source_py3 import OracleSource
+    from .azure_data_explorer_source_py3 import AzureDataExplorerSource
     from .azure_my_sql_source_py3 import AzureMySqlSource
     from .distcp_settings_py3 import DistcpSettings
     from .hdfs_source_py3 import HdfsSource
@@ -328,10 +354,13 @@
     from .staging_settings_py3 import StagingSettings
     from .tabular_translator_py3 import TabularTranslator
     from .copy_translator_py3 import CopyTranslator
+    from .cosmos_db_mongo_db_api_sink_py3 import CosmosDbMongoDbApiSink
     from .salesforce_sink_py3 import SalesforceSink
+    from .azure_data_explorer_sink_py3 import AzureDataExplorerSink
     from .dynamics_sink_py3 import DynamicsSink
     from .odbc_sink_py3 import OdbcSink
     from .azure_search_index_sink_py3 import AzureSearchIndexSink
+    from .azure_blob_fs_sink_py3 import AzureBlobFSSink
     from .azure_data_lake_store_sink_py3 import AzureDataLakeStoreSink
     from .oracle_sink_py3 import OracleSink
     from .polybase_settings_py3 import PolybaseSettings
@@ -466,6 +495,10 @@
     from .schedule_trigger import ScheduleTrigger
     from .multiple_pipeline_trigger import MultiplePipelineTrigger
     from .azure_function_linked_service import AzureFunctionLinkedService
+    from .azure_data_explorer_linked_service import AzureDataExplorerLinkedService
+    from .google_ad_words_linked_service import GoogleAdWordsLinkedService
+    from .oracle_service_cloud_linked_service import OracleServiceCloudLinkedService
+    from .dynamics_ax_linked_service import DynamicsAXLinkedService
     from .responsys_linked_service import ResponsysLinkedService
     from .azure_databricks_linked_service import AzureDatabricksLinkedService
     from .azure_data_lake_analytics_linked_service import AzureDataLakeAnalyticsLinkedService
@@ -514,7 +547,11 @@
     from .sap_ecc_linked_service import SapEccLinkedService
     from .sap_cloud_for_customer_linked_service import SapCloudForCustomerLinkedService
     from .salesforce_linked_service import SalesforceLinkedService
+    from .office365_linked_service import Office365LinkedService
+    from .azure_blob_fs_linked_service import AzureBlobFSLinkedService
     from .azure_data_lake_store_linked_service import AzureDataLakeStoreLinkedService
+    from .cosmos_db_mongo_db_api_linked_service import CosmosDbMongoDbApiLinkedService
+    from .mongo_db_v2_linked_service import MongoDbV2LinkedService
     from .mongo_db_linked_service import MongoDbLinkedService
     from .cassandra_linked_service import CassandraLinkedService
     from .web_client_certificate_authentication import WebClientCertificateAuthentication
@@ -545,6 +582,10 @@
     from .azure_table_storage_linked_service import AzureTableStorageLinkedService
     from .azure_blob_storage_linked_service import AzureBlobStorageLinkedService
     from .azure_storage_linked_service import AzureStorageLinkedService
+    from .google_ad_words_object_dataset import GoogleAdWordsObjectDataset
+    from .azure_data_explorer_table_dataset import AzureDataExplorerTableDataset
+    from .oracle_service_cloud_object_dataset import OracleServiceCloudObjectDataset
+    from .dynamics_ax_resource_dataset import DynamicsAXResourceDataset
     from .responsys_object_dataset import ResponsysObjectDataset
     from .salesforce_marketing_cloud_object_dataset import SalesforceMarketingCloudObjectDataset
     from .vertica_table_dataset import VerticaTableDataset
@@ -599,8 +640,13 @@
     from .azure_my_sql_table_dataset import AzureMySqlTableDataset
     from .oracle_table_dataset import OracleTableDataset
     from .odata_resource_dataset import ODataResourceDataset
+    from .cosmos_db_mongo_db_api_collection_dataset import CosmosDbMongoDbApiCollectionDataset
+    from .mongo_db_v2_collection_dataset import MongoDbV2CollectionDataset
     from .mongo_db_collection_dataset import MongoDbCollectionDataset
     from .file_share_dataset import FileShareDataset
+    from .azure_data_lake_store_cosmos_structured_stream_dataset import AzureDataLakeStoreCosmosStructuredStreamDataset
+    from .office365_dataset import Office365Dataset
+    from .azure_blob_fs_dataset import AzureBlobFSDataset
     from .azure_data_lake_store_dataset import AzureDataLakeStoreDataset
     from .dynamics_entity_dataset import DynamicsEntityDataset
     from .document_db_collection_dataset import DocumentDbCollectionDataset
@@ -625,6 +671,9 @@
     from .web_activity import WebActivity
     from .redshift_unload_settings import RedshiftUnloadSettings
     from .amazon_redshift_source import AmazonRedshiftSource
+    from .google_ad_words_source import GoogleAdWordsSource
+    from .oracle_service_cloud_source import OracleServiceCloudSource
+    from .dynamics_ax_source import DynamicsAXSource
     from .responsys_source import ResponsysSource
     from .salesforce_marketing_cloud_source import SalesforceMarketingCloudSource
     from .vertica_source import VerticaSource
@@ -656,11 +705,17 @@
     from .azure_postgre_sql_source import AzurePostgreSqlSource
     from .amazon_mws_source import AmazonMWSSource
     from .http_source import HttpSource
+    from .azure_blob_fs_source import AzureBlobFSSource
     from .azure_data_lake_store_source import AzureDataLakeStoreSource
+    from .office365_source import Office365Source
+    from .mongo_db_cursor_methods_properties import MongoDbCursorMethodsProperties
+    from .cosmos_db_mongo_db_api_source import CosmosDbMongoDbApiSource
+    from .mongo_db_v2_source import MongoDbV2Source
     from .mongo_db_source import MongoDbSource
     from .cassandra_source import CassandraSource
     from .web_source import WebSource
     from .oracle_source import OracleSource
+    from .azure_data_explorer_source import AzureDataExplorerSource
     from .azure_my_sql_source import AzureMySqlSource
     from .distcp_settings import DistcpSettings
     from .hdfs_source import HdfsSource
@@ -699,10 +754,13 @@
     from .staging_settings import StagingSettings
     from .tabular_translator import TabularTranslator
     from .copy_translator import CopyTranslator
+    from .cosmos_db_mongo_db_api_sink import CosmosDbMongoDbApiSink
     from .salesforce_sink import SalesforceSink
+    from .azure_data_explorer_sink import AzureDataExplorerSink
     from .dynamics_sink import DynamicsSink
     from .odbc_sink import OdbcSink
     from .azure_search_index_sink import AzureSearchIndexSink
+    from .azure_blob_fs_sink import AzureBlobFSSink
     from .azure_data_lake_store_sink import AzureDataLakeStoreSink
     from .oracle_sink import OracleSink
     from .polybase_settings import PolybaseSettings
@@ -776,6 +834,7 @@
     DayOfWeek,
     DaysOfWeek,
     RecurrenceFrequency,
+    GoogleAdWordsAuthenticationType,
     SparkServerType,
     SparkThriftTransportProtocol,
     SparkAuthenticationType,
@@ -795,6 +854,7 @@
     RestServiceAuthenticationType,
     MongoDbAuthenticationType,
     ODataAuthenticationType,
+    ODataAadServicePrincipalCredentialType,
     TeradataAuthenticationType,
     Db2AuthenticationType,
     SybaseAuthenticationType,
@@ -909,6 +969,10 @@
     'ScheduleTrigger',
     'MultiplePipelineTrigger',
     'AzureFunctionLinkedService',
+    'AzureDataExplorerLinkedService',
+    'GoogleAdWordsLinkedService',
+    'OracleServiceCloudLinkedService',
+    'DynamicsAXLinkedService',
     'ResponsysLinkedService',
     'AzureDatabricksLinkedService',
     'AzureDataLakeAnalyticsLinkedService',
@@ -957,7 +1021,11 @@
     'SapEccLinkedService',
     'SapCloudForCustomerLinkedService',
     'SalesforceLinkedService',
+    'Office365LinkedService',
+    'AzureBlobFSLinkedService',
     'AzureDataLakeStoreLinkedService',
+    'CosmosDbMongoDbApiLinkedService',
+    'MongoDbV2LinkedService',
     'MongoDbLinkedService',
     'CassandraLinkedService',
     'WebClientCertificateAuthentication',
@@ -988,6 +1056,10 @@
     'AzureTableStorageLinkedService',
     'AzureBlobStorageLinkedService',
     'AzureStorageLinkedService',
+    'GoogleAdWordsObjectDataset',
+    'AzureDataExplorerTableDataset',
+    'OracleServiceCloudObjectDataset',
+    'DynamicsAXResourceDataset',
     'ResponsysObjectDataset',
     'SalesforceMarketingCloudObjectDataset',
     'VerticaTableDataset',
@@ -1042,8 +1114,13 @@
     'AzureMySqlTableDataset',
     'OracleTableDataset',
     'ODataResourceDataset',
+    'CosmosDbMongoDbApiCollectionDataset',
+    'MongoDbV2CollectionDataset',
     'MongoDbCollectionDataset',
     'FileShareDataset',
+    'AzureDataLakeStoreCosmosStructuredStreamDataset',
+    'Office365Dataset',
+    'AzureBlobFSDataset',
     'AzureDataLakeStoreDataset',
     'DynamicsEntityDataset',
     'DocumentDbCollectionDataset',
@@ -1068,6 +1145,9 @@
     'WebActivity',
     'RedshiftUnloadSettings',
     'AmazonRedshiftSource',
+    'GoogleAdWordsSource',
+    'OracleServiceCloudSource',
+    'DynamicsAXSource',
     'ResponsysSource',
     'SalesforceMarketingCloudSource',
     'VerticaSource',
@@ -1099,11 +1179,17 @@
     'AzurePostgreSqlSource',
     'AmazonMWSSource',
     'HttpSource',
+    'AzureBlobFSSource',
     'AzureDataLakeStoreSource',
+    'Office365Source',
+    'MongoDbCursorMethodsProperties',
+    'CosmosDbMongoDbApiSource',
+    'MongoDbV2Source',
     'MongoDbSource',
     'CassandraSource',
     'WebSource',
     'OracleSource',
+    'AzureDataExplorerSource',
     'AzureMySqlSource',
     'DistcpSettings',
     'HdfsSource',
@@ -1142,10 +1228,13 @@
     'StagingSettings',
     'TabularTranslator',
     'CopyTranslator',
+    'CosmosDbMongoDbApiSink',
     'SalesforceSink',
+    'AzureDataExplorerSink',
     'DynamicsSink',
     'OdbcSink',
     'AzureSearchIndexSink',
+    'AzureBlobFSSink',
     'AzureDataLakeStoreSink',
     'OracleSink',
     'PolybaseSettings',
@@ -1218,6 +1307,7 @@
     'DayOfWeek',
     'DaysOfWeek',
     'RecurrenceFrequency',
+    'GoogleAdWordsAuthenticationType',
     'SparkServerType',
     'SparkThriftTransportProtocol',
     'SparkAuthenticationType',
@@ -1237,6 +1327,7 @@
     'RestServiceAuthenticationType',
     'MongoDbAuthenticationType',
     'ODataAuthenticationType',
+    'ODataAadServicePrincipalCredentialType',
     'TeradataAuthenticationType',
     'Db2AuthenticationType',
     'SybaseAuthenticationType',

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

@@ -27,6 +27,10 @@ class AmazonMWSSource(CopySource):
      with resultType string), pattern:
      ((\\d+)\\.)?(\\d\\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
     :type source_retry_wait: object
+    :param max_concurrent_connections: The maximum concurrent connection count
+     connectioned to source data store. Type: integer (or Expression with
+     resultType integer).
+    :type max_concurrent_connections: object
     :param type: Required. Constant filled by server.
     :type type: str
     :param query: A query to retrieve data from source. Type: string (or
@@ -42,6 +46,7 @@ class AmazonMWSSource(CopySource):
         'additional_properties': {'key': '', 'type': '{object}'},
         'source_retry_count': {'key': 'sourceRetryCount', 'type': 'object'},
         'source_retry_wait': {'key': 'sourceRetryWait', 'type': 'object'},
+        'max_concurrent_connections': {'key': 'maxConcurrentConnections', 'type': 'object'},
         'type': {'key': 'type', 'type': 'str'},
         'query': {'key': 'query', 'type': 'object'},
     }

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

@@ -27,6 +27,10 @@ class AmazonMWSSource(CopySource):
      with resultType string), pattern:
      ((\\d+)\\.)?(\\d\\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
     :type source_retry_wait: object
+    :param max_concurrent_connections: The maximum concurrent connection count
+     connectioned to source data store. Type: integer (or Expression with
+     resultType integer).
+    :type max_concurrent_connections: object
     :param type: Required. Constant filled by server.
     :type type: str
     :param query: A query to retrieve data from source. Type: string (or
@@ -42,11 +46,12 @@ class AmazonMWSSource(CopySource):
         'additional_properties': {'key': '', 'type': '{object}'},
         'source_retry_count': {'key': 'sourceRetryCount', 'type': 'object'},
         'source_retry_wait': {'key': 'sourceRetryWait', 'type': 'object'},
+        'max_concurrent_connections': {'key': 'maxConcurrentConnections', 'type': 'object'},
         'type': {'key': 'type', 'type': 'str'},
         'query': {'key': 'query', 'type': 'object'},
     }
 
-    def __init__(self, *, additional_properties=None, source_retry_count=None, source_retry_wait=None, query=None, **kwargs) -> None:
-        super(AmazonMWSSource, self).__init__(additional_properties=additional_properties, source_retry_count=source_retry_count, source_retry_wait=source_retry_wait, **kwargs)
+    def __init__(self, *, additional_properties=None, source_retry_count=None, source_retry_wait=None, max_concurrent_connections=None, query=None, **kwargs) -> None:
+        super(AmazonMWSSource, self).__init__(additional_properties=additional_properties, source_retry_count=source_retry_count, source_retry_wait=source_retry_wait, max_concurrent_connections=max_concurrent_connections, **kwargs)
         self.query = query
         self.type = 'AmazonMWSSource'

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

@@ -27,6 +27,10 @@ class AmazonRedshiftSource(CopySource):
      with resultType string), pattern:
      ((\\d+)\\.)?(\\d\\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
     :type source_retry_wait: object
+    :param max_concurrent_connections: The maximum concurrent connection count
+     connectioned to source data store. Type: integer (or Expression with
+     resultType integer).
+    :type max_concurrent_connections: object
     :param type: Required. Constant filled by server.
     :type type: str
     :param query: Database query. Type: string (or Expression with resultType
@@ -48,6 +52,7 @@ class AmazonRedshiftSource(CopySource):
         'additional_properties': {'key': '', 'type': '{object}'},
         'source_retry_count': {'key': 'sourceRetryCount', 'type': 'object'},
         'source_retry_wait': {'key': 'sourceRetryWait', 'type': 'object'},
+        'max_concurrent_connections': {'key': 'maxConcurrentConnections', 'type': 'object'},
         'type': {'key': 'type', 'type': 'str'},
         'query': {'key': 'query', 'type': 'object'},
         'redshift_unload_settings': {'key': 'redshiftUnloadSettings', 'type': 'RedshiftUnloadSettings'},