diff --git a/sdk/datafactory/azure-mgmt-datafactory/_meta.json b/sdk/datafactory/azure-mgmt-datafactory/_meta.json index d87d383e6363..b7c3ac34a772 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/_meta.json +++ b/sdk/datafactory/azure-mgmt-datafactory/_meta.json @@ -4,8 +4,8 @@ "@autorest/python@5.12.0", "@autorest/modelerfour@4.19.3" ], - "commit": "291dc1769270252821f53a9590d185dae8dc5775", + "commit": "d4ce2c30fbc45f9d73dccfa5de7a30711c6bb281", "repository_url": "https://github.com/Azure/azure-rest-api-specs", - "autorest_command": "autorest specification/datafactory/resource-manager/readme.md --multiapi --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/azure-sdk-for-python/sdk --python3-only --track2 --use=@autorest/python@5.12.0 --use=@autorest/modelerfour@4.19.3 --version=3.7.2", + "autorest_command": "autorest specification/datafactory/resource-manager/readme.md --multiapi --python --python-sdks-folder=/mnt/vss/_work/1/s/azure-sdk-for-python/sdk --python3-only --use=@autorest/python@5.12.0 --use=@autorest/modelerfour@4.19.3 --version=3.7.2", "readme": "specification/datafactory/resource-manager/readme.md" } \ No newline at end of file diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py index 6398307550c1..c47f66669f1b 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py @@ -6,4 +6,4 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -VERSION = "2.3.0" +VERSION = "1.0.0" diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py index 07464d7d9f68..2ed5dafb742a 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py @@ -34,8 +34,10 @@ from ._models_py3 import AmazonS3LinkedService from ._models_py3 import AmazonS3Location from ._models_py3 import AmazonS3ReadSettings +from ._models_py3 import AppFiguresLinkedService from ._models_py3 import AppendVariableActivity from ._models_py3 import ArmIdWrapper +from ._models_py3 import AsanaLinkedService from ._models_py3 import AvroDataset from ._models_py3 import AvroFormat from ._models_py3 import AvroSink @@ -205,6 +207,7 @@ from ._models_py3 import DatasetResource from ._models_py3 import DatasetSchemaDataElement from ._models_py3 import DatasetStorageFormat +from ._models_py3 import DataworldLinkedService from ._models_py3 import Db2LinkedService from ._models_py3 import Db2Source from ._models_py3 import Db2TableDataset @@ -246,6 +249,7 @@ from ._models_py3 import ExecuteDataFlowActivityTypeProperties from ._models_py3 import ExecuteDataFlowActivityTypePropertiesCompute from ._models_py3 import ExecutePipelineActivity +from ._models_py3 import ExecutePipelineActivityPolicy from ._models_py3 import ExecutePowerQueryActivityTypeProperties from ._models_py3 import ExecuteSSISPackageActivity from ._models_py3 import ExecuteWranglingDataflowActivity @@ -670,6 +674,7 @@ from ._models_py3 import TriggerSubscriptionOperationStatus from ._models_py3 import TumblingWindowTrigger from ._models_py3 import TumblingWindowTriggerDependencyReference +from ._models_py3 import TwilioLinkedService from ._models_py3 import TypeConversionSettings from ._models_py3 import UntilActivity from ._models_py3 import UpdateIntegrationRuntimeNodeRequest @@ -717,8 +722,10 @@ CopyBehaviorType, CosmosDbConnectionMode, CosmosDbServicePrincipalCredentialType, + CredentialReferenceType, DataFlowComputeType, DataFlowDebugCommandType, + DataFlowReferenceType, DatasetCompressionLevel, DayOfWeek, DaysOfWeek, @@ -754,6 +761,7 @@ JsonFormatFilePattern, JsonWriteFilePattern, ManagedIntegrationRuntimeNodeStatus, + ManagedVirtualNetworkReferenceType, MongoDbAuthenticationType, NetezzaPartitionOption, ODataAadServicePrincipalCredentialType, @@ -800,6 +808,7 @@ TeamDeskAuthenticationType, TeradataAuthenticationType, TeradataPartitionOption, + TriggerReferenceType, TriggerRunStatus, TriggerRuntimeState, TumblingWindowFrequency, @@ -839,8 +848,10 @@ 'AmazonS3LinkedService', 'AmazonS3Location', 'AmazonS3ReadSettings', + 'AppFiguresLinkedService', 'AppendVariableActivity', 'ArmIdWrapper', + 'AsanaLinkedService', 'AvroDataset', 'AvroFormat', 'AvroSink', @@ -1010,6 +1021,7 @@ 'DatasetResource', 'DatasetSchemaDataElement', 'DatasetStorageFormat', + 'DataworldLinkedService', 'Db2LinkedService', 'Db2Source', 'Db2TableDataset', @@ -1051,6 +1063,7 @@ 'ExecuteDataFlowActivityTypeProperties', 'ExecuteDataFlowActivityTypePropertiesCompute', 'ExecutePipelineActivity', + 'ExecutePipelineActivityPolicy', 'ExecutePowerQueryActivityTypeProperties', 'ExecuteSSISPackageActivity', 'ExecuteWranglingDataflowActivity', @@ -1475,6 +1488,7 @@ 'TriggerSubscriptionOperationStatus', 'TumblingWindowTrigger', 'TumblingWindowTriggerDependencyReference', + 'TwilioLinkedService', 'TypeConversionSettings', 'UntilActivity', 'UpdateIntegrationRuntimeNodeRequest', @@ -1519,8 +1533,10 @@ 'CopyBehaviorType', 'CosmosDbConnectionMode', 'CosmosDbServicePrincipalCredentialType', + 'CredentialReferenceType', 'DataFlowComputeType', 'DataFlowDebugCommandType', + 'DataFlowReferenceType', 'DatasetCompressionLevel', 'DayOfWeek', 'DaysOfWeek', @@ -1556,6 +1572,7 @@ 'JsonFormatFilePattern', 'JsonWriteFilePattern', 'ManagedIntegrationRuntimeNodeStatus', + 'ManagedVirtualNetworkReferenceType', 'MongoDbAuthenticationType', 'NetezzaPartitionOption', 'ODataAadServicePrincipalCredentialType', @@ -1602,6 +1619,7 @@ 'TeamDeskAuthenticationType', 'TeradataAuthenticationType', 'TeradataPartitionOption', + 'TriggerReferenceType', 'TriggerRunStatus', 'TriggerRuntimeState', 'TumblingWindowFrequency', diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py index e9fc3a46f184..554cca2051f0 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py @@ -107,6 +107,12 @@ class CosmosDbServicePrincipalCredentialType(with_metaclass(CaseInsensitiveEnumM SERVICE_PRINCIPAL_KEY = "ServicePrincipalKey" SERVICE_PRINCIPAL_CERT = "ServicePrincipalCert" +class CredentialReferenceType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): + """Credential reference type. + """ + + CREDENTIAL_REFERENCE = "CredentialReference" + class DataFlowComputeType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): """Compute type of the cluster which will execute data flow job. """ @@ -123,6 +129,12 @@ class DataFlowDebugCommandType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum EXECUTE_STATISTICS_QUERY = "executeStatisticsQuery" EXECUTE_EXPRESSION_QUERY = "executeExpressionQuery" +class DataFlowReferenceType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): + """Data flow reference type. + """ + + DATA_FLOW_REFERENCE = "DataFlowReference" + class DatasetCompressionLevel(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): """All available compression levels. """ @@ -412,6 +424,12 @@ class ManagedIntegrationRuntimeNodeStatus(with_metaclass(CaseInsensitiveEnumMeta RECYCLING = "Recycling" UNAVAILABLE = "Unavailable" +class ManagedVirtualNetworkReferenceType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): + """Managed Virtual Network reference type. + """ + + MANAGED_VIRTUAL_NETWORK_REFERENCE = "ManagedVirtualNetworkReference" + class MongoDbAuthenticationType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): """The authentication type to be used to connect to the MongoDB database. """ @@ -816,6 +834,12 @@ class TeradataPartitionOption(with_metaclass(CaseInsensitiveEnumMeta, str, Enum) HASH = "Hash" DYNAMIC_RANGE = "DynamicRange" +class TriggerReferenceType(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): + """Trigger reference type. + """ + + TRIGGER_REFERENCE = "TriggerReference" + class TriggerRunStatus(with_metaclass(CaseInsensitiveEnumMeta, str, Enum)): """Trigger run status. """ 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 f92407c06e0f..1f3267a1c40f 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 @@ -451,7 +451,7 @@ class LinkedService(msrest.serialization.Model): """The Azure Data Factory nested object which contains the information and credential which can be used to connect with related store or compute resource. You probably want to use the sub-classes and not this class directly. Known - sub-classes are: AmazonMWSLinkedService, AmazonRdsForOracleLinkedService, AmazonRdsForSqlServerLinkedService, AmazonRedshiftLinkedService, AmazonS3LinkedService, AmazonS3CompatibleLinkedService, AzureBatchLinkedService, AzureBlobFSLinkedService, AzureBlobStorageLinkedService, AzureDataExplorerLinkedService, AzureDataLakeAnalyticsLinkedService, AzureDataLakeStoreLinkedService, AzureDatabricksLinkedService, AzureDatabricksDeltaLakeLinkedService, AzureFileStorageLinkedService, AzureFunctionLinkedService, AzureKeyVaultLinkedService, AzureMLLinkedService, AzureMLServiceLinkedService, AzureMariaDBLinkedService, AzureMySqlLinkedService, AzurePostgreSqlLinkedService, AzureSearchLinkedService, AzureSqlDWLinkedService, AzureSqlDatabaseLinkedService, AzureSqlMILinkedService, AzureStorageLinkedService, AzureTableStorageLinkedService, CassandraLinkedService, CommonDataServiceForAppsLinkedService, ConcurLinkedService, CosmosDbLinkedService, CosmosDbMongoDbApiLinkedService, CouchbaseLinkedService, CustomDataSourceLinkedService, Db2LinkedService, DrillLinkedService, DynamicsLinkedService, DynamicsAXLinkedService, DynamicsCrmLinkedService, EloquaLinkedService, FileServerLinkedService, FtpServerLinkedService, GoogleAdWordsLinkedService, GoogleBigQueryLinkedService, GoogleCloudStorageLinkedService, GreenplumLinkedService, HBaseLinkedService, HDInsightLinkedService, HDInsightOnDemandLinkedService, HdfsLinkedService, HiveLinkedService, HttpLinkedService, HubspotLinkedService, ImpalaLinkedService, InformixLinkedService, JiraLinkedService, MagentoLinkedService, MariaDBLinkedService, MarketoLinkedService, MicrosoftAccessLinkedService, MongoDbLinkedService, MongoDbAtlasLinkedService, MongoDbV2LinkedService, MySqlLinkedService, NetezzaLinkedService, ODataLinkedService, OdbcLinkedService, Office365LinkedService, OracleLinkedService, OracleCloudStorageLinkedService, OracleServiceCloudLinkedService, PaypalLinkedService, PhoenixLinkedService, PostgreSqlLinkedService, PrestoLinkedService, QuickBooksLinkedService, QuickbaseLinkedService, ResponsysLinkedService, RestServiceLinkedService, SalesforceLinkedService, SalesforceMarketingCloudLinkedService, SalesforceServiceCloudLinkedService, SapBWLinkedService, SapCloudForCustomerLinkedService, SapEccLinkedService, SapHanaLinkedService, SapOpenHubLinkedService, SapTableLinkedService, ServiceNowLinkedService, SftpServerLinkedService, SharePointOnlineListLinkedService, ShopifyLinkedService, SmartsheetLinkedService, SnowflakeLinkedService, SparkLinkedService, SqlServerLinkedService, SquareLinkedService, SybaseLinkedService, TeamDeskLinkedService, TeradataLinkedService, VerticaLinkedService, WebLinkedService, XeroLinkedService, ZendeskLinkedService, ZohoLinkedService. + sub-classes are: AmazonMWSLinkedService, AmazonRdsForOracleLinkedService, AmazonRdsForSqlServerLinkedService, AmazonRedshiftLinkedService, AmazonS3LinkedService, AmazonS3CompatibleLinkedService, AppFiguresLinkedService, AsanaLinkedService, AzureBatchLinkedService, AzureBlobFSLinkedService, AzureBlobStorageLinkedService, AzureDataExplorerLinkedService, AzureDataLakeAnalyticsLinkedService, AzureDataLakeStoreLinkedService, AzureDatabricksLinkedService, AzureDatabricksDeltaLakeLinkedService, AzureFileStorageLinkedService, AzureFunctionLinkedService, AzureKeyVaultLinkedService, AzureMLLinkedService, AzureMLServiceLinkedService, AzureMariaDBLinkedService, AzureMySqlLinkedService, AzurePostgreSqlLinkedService, AzureSearchLinkedService, AzureSqlDWLinkedService, AzureSqlDatabaseLinkedService, AzureSqlMILinkedService, AzureStorageLinkedService, AzureTableStorageLinkedService, CassandraLinkedService, CommonDataServiceForAppsLinkedService, ConcurLinkedService, CosmosDbLinkedService, CosmosDbMongoDbApiLinkedService, CouchbaseLinkedService, CustomDataSourceLinkedService, DataworldLinkedService, Db2LinkedService, DrillLinkedService, DynamicsLinkedService, DynamicsAXLinkedService, DynamicsCrmLinkedService, EloquaLinkedService, FileServerLinkedService, FtpServerLinkedService, GoogleAdWordsLinkedService, GoogleBigQueryLinkedService, GoogleCloudStorageLinkedService, GreenplumLinkedService, HBaseLinkedService, HDInsightLinkedService, HDInsightOnDemandLinkedService, HdfsLinkedService, HiveLinkedService, HttpLinkedService, HubspotLinkedService, ImpalaLinkedService, InformixLinkedService, JiraLinkedService, MagentoLinkedService, MariaDBLinkedService, MarketoLinkedService, MicrosoftAccessLinkedService, MongoDbLinkedService, MongoDbAtlasLinkedService, MongoDbV2LinkedService, MySqlLinkedService, NetezzaLinkedService, ODataLinkedService, OdbcLinkedService, Office365LinkedService, OracleLinkedService, OracleCloudStorageLinkedService, OracleServiceCloudLinkedService, PaypalLinkedService, PhoenixLinkedService, PostgreSqlLinkedService, PrestoLinkedService, QuickBooksLinkedService, QuickbaseLinkedService, ResponsysLinkedService, RestServiceLinkedService, SalesforceLinkedService, SalesforceMarketingCloudLinkedService, SalesforceServiceCloudLinkedService, SapBWLinkedService, SapCloudForCustomerLinkedService, SapEccLinkedService, SapHanaLinkedService, SapOpenHubLinkedService, SapTableLinkedService, ServiceNowLinkedService, SftpServerLinkedService, SharePointOnlineListLinkedService, ShopifyLinkedService, SmartsheetLinkedService, SnowflakeLinkedService, SparkLinkedService, SqlServerLinkedService, SquareLinkedService, SybaseLinkedService, TeamDeskLinkedService, TeradataLinkedService, TwilioLinkedService, VerticaLinkedService, WebLinkedService, XeroLinkedService, ZendeskLinkedService, ZohoLinkedService. All required parameters must be populated in order to send to Azure. @@ -484,7 +484,7 @@ class LinkedService(msrest.serialization.Model): } _subtype_map = { - 'type': {'AmazonMWS': 'AmazonMWSLinkedService', 'AmazonRdsForOracle': 'AmazonRdsForOracleLinkedService', 'AmazonRdsForSqlServer': 'AmazonRdsForSqlServerLinkedService', 'AmazonRedshift': 'AmazonRedshiftLinkedService', 'AmazonS3': 'AmazonS3LinkedService', 'AmazonS3Compatible': 'AmazonS3CompatibleLinkedService', 'AzureBatch': 'AzureBatchLinkedService', 'AzureBlobFS': 'AzureBlobFSLinkedService', 'AzureBlobStorage': 'AzureBlobStorageLinkedService', 'AzureDataExplorer': 'AzureDataExplorerLinkedService', 'AzureDataLakeAnalytics': 'AzureDataLakeAnalyticsLinkedService', 'AzureDataLakeStore': 'AzureDataLakeStoreLinkedService', 'AzureDatabricks': 'AzureDatabricksLinkedService', 'AzureDatabricksDeltaLake': 'AzureDatabricksDeltaLakeLinkedService', 'AzureFileStorage': 'AzureFileStorageLinkedService', 'AzureFunction': 'AzureFunctionLinkedService', 'AzureKeyVault': 'AzureKeyVaultLinkedService', 'AzureML': 'AzureMLLinkedService', 'AzureMLService': 'AzureMLServiceLinkedService', 'AzureMariaDB': 'AzureMariaDBLinkedService', 'AzureMySql': 'AzureMySqlLinkedService', 'AzurePostgreSql': 'AzurePostgreSqlLinkedService', 'AzureSearch': 'AzureSearchLinkedService', 'AzureSqlDW': 'AzureSqlDWLinkedService', 'AzureSqlDatabase': 'AzureSqlDatabaseLinkedService', 'AzureSqlMI': 'AzureSqlMILinkedService', 'AzureStorage': 'AzureStorageLinkedService', 'AzureTableStorage': 'AzureTableStorageLinkedService', 'Cassandra': 'CassandraLinkedService', 'CommonDataServiceForApps': 'CommonDataServiceForAppsLinkedService', 'Concur': 'ConcurLinkedService', 'CosmosDb': 'CosmosDbLinkedService', 'CosmosDbMongoDbApi': 'CosmosDbMongoDbApiLinkedService', 'Couchbase': 'CouchbaseLinkedService', 'CustomDataSource': 'CustomDataSourceLinkedService', 'Db2': 'Db2LinkedService', 'Drill': 'DrillLinkedService', 'Dynamics': 'DynamicsLinkedService', 'DynamicsAX': 'DynamicsAXLinkedService', 'DynamicsCrm': 'DynamicsCrmLinkedService', 'Eloqua': 'EloquaLinkedService', 'FileServer': 'FileServerLinkedService', 'FtpServer': 'FtpServerLinkedService', 'GoogleAdWords': 'GoogleAdWordsLinkedService', 'GoogleBigQuery': 'GoogleBigQueryLinkedService', 'GoogleCloudStorage': 'GoogleCloudStorageLinkedService', 'Greenplum': 'GreenplumLinkedService', 'HBase': 'HBaseLinkedService', 'HDInsight': 'HDInsightLinkedService', 'HDInsightOnDemand': 'HDInsightOnDemandLinkedService', 'Hdfs': 'HdfsLinkedService', 'Hive': 'HiveLinkedService', 'HttpServer': 'HttpLinkedService', 'Hubspot': 'HubspotLinkedService', 'Impala': 'ImpalaLinkedService', 'Informix': 'InformixLinkedService', 'Jira': 'JiraLinkedService', 'Magento': 'MagentoLinkedService', 'MariaDB': 'MariaDBLinkedService', 'Marketo': 'MarketoLinkedService', 'MicrosoftAccess': 'MicrosoftAccessLinkedService', 'MongoDb': 'MongoDbLinkedService', 'MongoDbAtlas': 'MongoDbAtlasLinkedService', 'MongoDbV2': 'MongoDbV2LinkedService', 'MySql': 'MySqlLinkedService', 'Netezza': 'NetezzaLinkedService', 'OData': 'ODataLinkedService', 'Odbc': 'OdbcLinkedService', 'Office365': 'Office365LinkedService', 'Oracle': 'OracleLinkedService', 'OracleCloudStorage': 'OracleCloudStorageLinkedService', 'OracleServiceCloud': 'OracleServiceCloudLinkedService', 'Paypal': 'PaypalLinkedService', 'Phoenix': 'PhoenixLinkedService', 'PostgreSql': 'PostgreSqlLinkedService', 'Presto': 'PrestoLinkedService', 'QuickBooks': 'QuickBooksLinkedService', 'Quickbase': 'QuickbaseLinkedService', 'Responsys': 'ResponsysLinkedService', 'RestService': 'RestServiceLinkedService', 'Salesforce': 'SalesforceLinkedService', 'SalesforceMarketingCloud': 'SalesforceMarketingCloudLinkedService', 'SalesforceServiceCloud': 'SalesforceServiceCloudLinkedService', 'SapBW': 'SapBWLinkedService', 'SapCloudForCustomer': 'SapCloudForCustomerLinkedService', 'SapEcc': 'SapEccLinkedService', 'SapHana': 'SapHanaLinkedService', 'SapOpenHub': 'SapOpenHubLinkedService', 'SapTable': 'SapTableLinkedService', 'ServiceNow': 'ServiceNowLinkedService', 'Sftp': 'SftpServerLinkedService', 'SharePointOnlineList': 'SharePointOnlineListLinkedService', 'Shopify': 'ShopifyLinkedService', 'Smartsheet': 'SmartsheetLinkedService', 'Snowflake': 'SnowflakeLinkedService', 'Spark': 'SparkLinkedService', 'SqlServer': 'SqlServerLinkedService', 'Square': 'SquareLinkedService', 'Sybase': 'SybaseLinkedService', 'TeamDesk': 'TeamDeskLinkedService', 'Teradata': 'TeradataLinkedService', 'Vertica': 'VerticaLinkedService', 'Web': 'WebLinkedService', 'Xero': 'XeroLinkedService', 'Zendesk': 'ZendeskLinkedService', 'Zoho': 'ZohoLinkedService'} + 'type': {'AmazonMWS': 'AmazonMWSLinkedService', 'AmazonRdsForOracle': 'AmazonRdsForOracleLinkedService', 'AmazonRdsForSqlServer': 'AmazonRdsForSqlServerLinkedService', 'AmazonRedshift': 'AmazonRedshiftLinkedService', 'AmazonS3': 'AmazonS3LinkedService', 'AmazonS3Compatible': 'AmazonS3CompatibleLinkedService', 'AppFigures': 'AppFiguresLinkedService', 'Asana': 'AsanaLinkedService', 'AzureBatch': 'AzureBatchLinkedService', 'AzureBlobFS': 'AzureBlobFSLinkedService', 'AzureBlobStorage': 'AzureBlobStorageLinkedService', 'AzureDataExplorer': 'AzureDataExplorerLinkedService', 'AzureDataLakeAnalytics': 'AzureDataLakeAnalyticsLinkedService', 'AzureDataLakeStore': 'AzureDataLakeStoreLinkedService', 'AzureDatabricks': 'AzureDatabricksLinkedService', 'AzureDatabricksDeltaLake': 'AzureDatabricksDeltaLakeLinkedService', 'AzureFileStorage': 'AzureFileStorageLinkedService', 'AzureFunction': 'AzureFunctionLinkedService', 'AzureKeyVault': 'AzureKeyVaultLinkedService', 'AzureML': 'AzureMLLinkedService', 'AzureMLService': 'AzureMLServiceLinkedService', 'AzureMariaDB': 'AzureMariaDBLinkedService', 'AzureMySql': 'AzureMySqlLinkedService', 'AzurePostgreSql': 'AzurePostgreSqlLinkedService', 'AzureSearch': 'AzureSearchLinkedService', 'AzureSqlDW': 'AzureSqlDWLinkedService', 'AzureSqlDatabase': 'AzureSqlDatabaseLinkedService', 'AzureSqlMI': 'AzureSqlMILinkedService', 'AzureStorage': 'AzureStorageLinkedService', 'AzureTableStorage': 'AzureTableStorageLinkedService', 'Cassandra': 'CassandraLinkedService', 'CommonDataServiceForApps': 'CommonDataServiceForAppsLinkedService', 'Concur': 'ConcurLinkedService', 'CosmosDb': 'CosmosDbLinkedService', 'CosmosDbMongoDbApi': 'CosmosDbMongoDbApiLinkedService', 'Couchbase': 'CouchbaseLinkedService', 'CustomDataSource': 'CustomDataSourceLinkedService', 'Dataworld': 'DataworldLinkedService', 'Db2': 'Db2LinkedService', 'Drill': 'DrillLinkedService', 'Dynamics': 'DynamicsLinkedService', 'DynamicsAX': 'DynamicsAXLinkedService', 'DynamicsCrm': 'DynamicsCrmLinkedService', 'Eloqua': 'EloquaLinkedService', 'FileServer': 'FileServerLinkedService', 'FtpServer': 'FtpServerLinkedService', 'GoogleAdWords': 'GoogleAdWordsLinkedService', 'GoogleBigQuery': 'GoogleBigQueryLinkedService', 'GoogleCloudStorage': 'GoogleCloudStorageLinkedService', 'Greenplum': 'GreenplumLinkedService', 'HBase': 'HBaseLinkedService', 'HDInsight': 'HDInsightLinkedService', 'HDInsightOnDemand': 'HDInsightOnDemandLinkedService', 'Hdfs': 'HdfsLinkedService', 'Hive': 'HiveLinkedService', 'HttpServer': 'HttpLinkedService', 'Hubspot': 'HubspotLinkedService', 'Impala': 'ImpalaLinkedService', 'Informix': 'InformixLinkedService', 'Jira': 'JiraLinkedService', 'Magento': 'MagentoLinkedService', 'MariaDB': 'MariaDBLinkedService', 'Marketo': 'MarketoLinkedService', 'MicrosoftAccess': 'MicrosoftAccessLinkedService', 'MongoDb': 'MongoDbLinkedService', 'MongoDbAtlas': 'MongoDbAtlasLinkedService', 'MongoDbV2': 'MongoDbV2LinkedService', 'MySql': 'MySqlLinkedService', 'Netezza': 'NetezzaLinkedService', 'OData': 'ODataLinkedService', 'Odbc': 'OdbcLinkedService', 'Office365': 'Office365LinkedService', 'Oracle': 'OracleLinkedService', 'OracleCloudStorage': 'OracleCloudStorageLinkedService', 'OracleServiceCloud': 'OracleServiceCloudLinkedService', 'Paypal': 'PaypalLinkedService', 'Phoenix': 'PhoenixLinkedService', 'PostgreSql': 'PostgreSqlLinkedService', 'Presto': 'PrestoLinkedService', 'QuickBooks': 'QuickBooksLinkedService', 'Quickbase': 'QuickbaseLinkedService', 'Responsys': 'ResponsysLinkedService', 'RestService': 'RestServiceLinkedService', 'Salesforce': 'SalesforceLinkedService', 'SalesforceMarketingCloud': 'SalesforceMarketingCloudLinkedService', 'SalesforceServiceCloud': 'SalesforceServiceCloudLinkedService', 'SapBW': 'SapBWLinkedService', 'SapCloudForCustomer': 'SapCloudForCustomerLinkedService', 'SapEcc': 'SapEccLinkedService', 'SapHana': 'SapHanaLinkedService', 'SapOpenHub': 'SapOpenHubLinkedService', 'SapTable': 'SapTableLinkedService', 'ServiceNow': 'ServiceNowLinkedService', 'Sftp': 'SftpServerLinkedService', 'SharePointOnlineList': 'SharePointOnlineListLinkedService', 'Shopify': 'ShopifyLinkedService', 'Smartsheet': 'SmartsheetLinkedService', 'Snowflake': 'SnowflakeLinkedService', 'Spark': 'SparkLinkedService', 'SqlServer': 'SqlServerLinkedService', 'Square': 'SquareLinkedService', 'Sybase': 'SybaseLinkedService', 'TeamDesk': 'TeamDeskLinkedService', 'Teradata': 'TeradataLinkedService', 'Twilio': 'TwilioLinkedService', 'Vertica': 'VerticaLinkedService', 'Web': 'WebLinkedService', 'Xero': 'XeroLinkedService', 'Zendesk': 'ZendeskLinkedService', 'Zoho': 'ZohoLinkedService'} } def __init__( @@ -3236,6 +3236,90 @@ def __init__( self.value = value +class AppFiguresLinkedService(LinkedService): + """Linked service for AppFigures. + + All required parameters must be populated in order to send to Azure. + + :ivar additional_properties: Unmatched properties from the message are deserialized to this + collection. + :vartype additional_properties: dict[str, any] + :ivar type: Required. Type of linked service.Constant filled by server. + :vartype type: str + :ivar connect_via: The integration runtime reference. + :vartype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :ivar description: Linked service description. + :vartype description: str + :ivar parameters: Parameters for linked service. + :vartype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :ivar annotations: List of tags that can be used for describing the linked service. + :vartype annotations: list[any] + :ivar user_name: Required. The username of the Appfigures source. + :vartype user_name: any + :ivar password: Required. The password of the AppFigures source. + :vartype password: ~azure.mgmt.datafactory.models.SecretBase + :ivar client_key: Required. The client key for the AppFigures source. + :vartype client_key: ~azure.mgmt.datafactory.models.SecretBase + """ + + _validation = { + 'type': {'required': True}, + 'user_name': {'required': True}, + 'password': {'required': True}, + 'client_key': {'required': True}, + } + + _attribute_map = { + 'additional_properties': {'key': '', 'type': '{object}'}, + 'type': {'key': 'type', 'type': 'str'}, + 'connect_via': {'key': 'connectVia', 'type': 'IntegrationRuntimeReference'}, + 'description': {'key': 'description', 'type': 'str'}, + 'parameters': {'key': 'parameters', 'type': '{ParameterSpecification}'}, + 'annotations': {'key': 'annotations', 'type': '[object]'}, + 'user_name': {'key': 'typeProperties.userName', 'type': 'object'}, + 'password': {'key': 'typeProperties.password', 'type': 'SecretBase'}, + 'client_key': {'key': 'typeProperties.clientKey', 'type': 'SecretBase'}, + } + + def __init__( + self, + *, + user_name: Any, + password: "SecretBase", + client_key: "SecretBase", + additional_properties: Optional[Dict[str, Any]] = None, + connect_via: Optional["IntegrationRuntimeReference"] = None, + description: Optional[str] = None, + parameters: Optional[Dict[str, "ParameterSpecification"]] = None, + annotations: Optional[List[Any]] = None, + **kwargs + ): + """ + :keyword additional_properties: Unmatched properties from the message are deserialized to this + collection. + :paramtype additional_properties: dict[str, any] + :keyword connect_via: The integration runtime reference. + :paramtype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :keyword description: Linked service description. + :paramtype description: str + :keyword parameters: Parameters for linked service. + :paramtype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :keyword annotations: List of tags that can be used for describing the linked service. + :paramtype annotations: list[any] + :keyword user_name: Required. The username of the Appfigures source. + :paramtype user_name: any + :keyword password: Required. The password of the AppFigures source. + :paramtype password: ~azure.mgmt.datafactory.models.SecretBase + :keyword client_key: Required. The client key for the AppFigures source. + :paramtype client_key: ~azure.mgmt.datafactory.models.SecretBase + """ + super(AppFiguresLinkedService, self).__init__(additional_properties=additional_properties, connect_via=connect_via, description=description, parameters=parameters, annotations=annotations, **kwargs) + self.type = 'AppFigures' # type: str + self.user_name = user_name + self.password = password + self.client_key = client_key + + class ArmIdWrapper(msrest.serialization.Model): """A wrapper for an ARM resource id. @@ -3263,6 +3347,85 @@ def __init__( self.id = None +class AsanaLinkedService(LinkedService): + """Linked service for Asana. + + All required parameters must be populated in order to send to Azure. + + :ivar additional_properties: Unmatched properties from the message are deserialized to this + collection. + :vartype additional_properties: dict[str, any] + :ivar type: Required. Type of linked service.Constant filled by server. + :vartype type: str + :ivar connect_via: The integration runtime reference. + :vartype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :ivar description: Linked service description. + :vartype description: str + :ivar parameters: Parameters for linked service. + :vartype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :ivar annotations: List of tags that can be used for describing the linked service. + :vartype annotations: list[any] + :ivar api_token: Required. The api token for the Asana source. + :vartype api_token: ~azure.mgmt.datafactory.models.SecretBase + :ivar encrypted_credential: The encrypted credential used for authentication. Credentials are + encrypted using the integration runtime credential manager. Type: string (or Expression with + resultType string). + :vartype encrypted_credential: any + """ + + _validation = { + 'type': {'required': True}, + 'api_token': {'required': True}, + } + + _attribute_map = { + 'additional_properties': {'key': '', 'type': '{object}'}, + 'type': {'key': 'type', 'type': 'str'}, + 'connect_via': {'key': 'connectVia', 'type': 'IntegrationRuntimeReference'}, + 'description': {'key': 'description', 'type': 'str'}, + 'parameters': {'key': 'parameters', 'type': '{ParameterSpecification}'}, + 'annotations': {'key': 'annotations', 'type': '[object]'}, + 'api_token': {'key': 'typeProperties.apiToken', 'type': 'SecretBase'}, + 'encrypted_credential': {'key': 'typeProperties.encryptedCredential', 'type': 'object'}, + } + + def __init__( + self, + *, + api_token: "SecretBase", + additional_properties: Optional[Dict[str, Any]] = None, + connect_via: Optional["IntegrationRuntimeReference"] = None, + description: Optional[str] = None, + parameters: Optional[Dict[str, "ParameterSpecification"]] = None, + annotations: Optional[List[Any]] = None, + encrypted_credential: Optional[Any] = None, + **kwargs + ): + """ + :keyword additional_properties: Unmatched properties from the message are deserialized to this + collection. + :paramtype additional_properties: dict[str, any] + :keyword connect_via: The integration runtime reference. + :paramtype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :keyword description: Linked service description. + :paramtype description: str + :keyword parameters: Parameters for linked service. + :paramtype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :keyword annotations: List of tags that can be used for describing the linked service. + :paramtype annotations: list[any] + :keyword api_token: Required. The api token for the Asana source. + :paramtype api_token: ~azure.mgmt.datafactory.models.SecretBase + :keyword encrypted_credential: The encrypted credential used for authentication. Credentials + are encrypted using the integration runtime credential manager. Type: string (or Expression + with resultType string). + :paramtype encrypted_credential: any + """ + super(AsanaLinkedService, self).__init__(additional_properties=additional_properties, connect_via=connect_via, description=description, parameters=parameters, annotations=annotations, **kwargs) + self.type = 'Asana' # type: str + self.api_token = api_token + self.encrypted_credential = encrypted_credential + + class AvroDataset(Dataset): """Avro dataset. @@ -16261,21 +16424,20 @@ def __init__( class CredentialReference(msrest.serialization.Model): """Credential reference type. - Variables are only populated by the server, and will be ignored when sending a request. - All required parameters must be populated in order to send to Azure. :ivar additional_properties: Unmatched properties from the message are deserialized to this collection. :vartype additional_properties: dict[str, any] - :ivar type: Credential reference type. Has constant value: "CredentialReference". - :vartype type: str + :ivar type: Required. Credential reference type. Possible values include: + "CredentialReference". + :vartype type: str or ~azure.mgmt.datafactory.models.CredentialReferenceType :ivar reference_name: Required. Reference credential name. :vartype reference_name: str """ _validation = { - 'type': {'required': True, 'constant': True}, + 'type': {'required': True}, 'reference_name': {'required': True}, } @@ -16285,11 +16447,10 @@ class CredentialReference(msrest.serialization.Model): 'reference_name': {'key': 'referenceName', 'type': 'str'}, } - type = "CredentialReference" - def __init__( self, *, + type: Union[str, "CredentialReferenceType"], reference_name: str, additional_properties: Optional[Dict[str, Any]] = None, **kwargs @@ -16298,11 +16459,15 @@ def __init__( :keyword additional_properties: Unmatched properties from the message are deserialized to this collection. :paramtype additional_properties: dict[str, any] + :keyword type: Required. Credential reference type. Possible values include: + "CredentialReference". + :paramtype type: str or ~azure.mgmt.datafactory.models.CredentialReferenceType :keyword reference_name: Required. Reference credential name. :paramtype reference_name: str """ super(CredentialReference, self).__init__(**kwargs) self.additional_properties = additional_properties + self.type = type self.reference_name = reference_name @@ -17636,15 +17801,13 @@ def __init__( class DataFlowReference(msrest.serialization.Model): """Data flow reference type. - Variables are only populated by the server, and will be ignored when sending a request. - All required parameters must be populated in order to send to Azure. :ivar additional_properties: Unmatched properties from the message are deserialized to this collection. :vartype additional_properties: dict[str, any] - :ivar type: Data flow reference type. Has constant value: "DataFlowReference". - :vartype type: str + :ivar type: Required. Data flow reference type. Possible values include: "DataFlowReference". + :vartype type: str or ~azure.mgmt.datafactory.models.DataFlowReferenceType :ivar reference_name: Required. Reference data flow name. :vartype reference_name: str :ivar dataset_parameters: Reference data flow parameters from dataset. @@ -17654,7 +17817,7 @@ class DataFlowReference(msrest.serialization.Model): """ _validation = { - 'type': {'required': True, 'constant': True}, + 'type': {'required': True}, 'reference_name': {'required': True}, } @@ -17666,11 +17829,10 @@ class DataFlowReference(msrest.serialization.Model): 'parameters': {'key': 'parameters', 'type': '{object}'}, } - type = "DataFlowReference" - def __init__( self, *, + type: Union[str, "DataFlowReferenceType"], reference_name: str, additional_properties: Optional[Dict[str, Any]] = None, dataset_parameters: Optional[Any] = None, @@ -17681,6 +17843,9 @@ def __init__( :keyword additional_properties: Unmatched properties from the message are deserialized to this collection. :paramtype additional_properties: dict[str, any] + :keyword type: Required. Data flow reference type. Possible values include: + "DataFlowReference". + :paramtype type: str or ~azure.mgmt.datafactory.models.DataFlowReferenceType :keyword reference_name: Required. Reference data flow name. :paramtype reference_name: str :keyword dataset_parameters: Reference data flow parameters from dataset. @@ -17690,6 +17855,7 @@ def __init__( """ super(DataFlowReference, self).__init__(**kwargs) self.additional_properties = additional_properties + self.type = type self.reference_name = reference_name self.dataset_parameters = dataset_parameters self.parameters = parameters @@ -18455,6 +18621,85 @@ def __init__( self.type = type +class DataworldLinkedService(LinkedService): + """Linked service for Dataworld. + + All required parameters must be populated in order to send to Azure. + + :ivar additional_properties: Unmatched properties from the message are deserialized to this + collection. + :vartype additional_properties: dict[str, any] + :ivar type: Required. Type of linked service.Constant filled by server. + :vartype type: str + :ivar connect_via: The integration runtime reference. + :vartype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :ivar description: Linked service description. + :vartype description: str + :ivar parameters: Parameters for linked service. + :vartype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :ivar annotations: List of tags that can be used for describing the linked service. + :vartype annotations: list[any] + :ivar api_token: Required. The api token for the Dataworld source. + :vartype api_token: ~azure.mgmt.datafactory.models.SecretBase + :ivar encrypted_credential: The encrypted credential used for authentication. Credentials are + encrypted using the integration runtime credential manager. Type: string (or Expression with + resultType string). + :vartype encrypted_credential: any + """ + + _validation = { + 'type': {'required': True}, + 'api_token': {'required': True}, + } + + _attribute_map = { + 'additional_properties': {'key': '', 'type': '{object}'}, + 'type': {'key': 'type', 'type': 'str'}, + 'connect_via': {'key': 'connectVia', 'type': 'IntegrationRuntimeReference'}, + 'description': {'key': 'description', 'type': 'str'}, + 'parameters': {'key': 'parameters', 'type': '{ParameterSpecification}'}, + 'annotations': {'key': 'annotations', 'type': '[object]'}, + 'api_token': {'key': 'typeProperties.apiToken', 'type': 'SecretBase'}, + 'encrypted_credential': {'key': 'typeProperties.encryptedCredential', 'type': 'object'}, + } + + def __init__( + self, + *, + api_token: "SecretBase", + additional_properties: Optional[Dict[str, Any]] = None, + connect_via: Optional["IntegrationRuntimeReference"] = None, + description: Optional[str] = None, + parameters: Optional[Dict[str, "ParameterSpecification"]] = None, + annotations: Optional[List[Any]] = None, + encrypted_credential: Optional[Any] = None, + **kwargs + ): + """ + :keyword additional_properties: Unmatched properties from the message are deserialized to this + collection. + :paramtype additional_properties: dict[str, any] + :keyword connect_via: The integration runtime reference. + :paramtype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :keyword description: Linked service description. + :paramtype description: str + :keyword parameters: Parameters for linked service. + :paramtype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :keyword annotations: List of tags that can be used for describing the linked service. + :paramtype annotations: list[any] + :keyword api_token: Required. The api token for the Dataworld source. + :paramtype api_token: ~azure.mgmt.datafactory.models.SecretBase + :keyword encrypted_credential: The encrypted credential used for authentication. Credentials + are encrypted using the integration runtime credential manager. Type: string (or Expression + with resultType string). + :paramtype encrypted_credential: any + """ + super(DataworldLinkedService, self).__init__(additional_properties=additional_properties, connect_via=connect_via, description=description, parameters=parameters, annotations=annotations, **kwargs) + self.type = 'Dataworld' # type: str + self.api_token = api_token + self.encrypted_credential = encrypted_credential + + class Db2LinkedService(LinkedService): """Linked service for DB2 data source. @@ -21149,7 +21394,7 @@ class DynamicsLinkedService(LinkedService): :ivar service_principal_credential_type: The service principal credential type to use in Server-To-Server authentication. 'ServicePrincipalKey' for key/secret, 'ServicePrincipalCert' for certificate. Type: string (or Expression with resultType string). - :vartype service_principal_credential_type: str + :vartype service_principal_credential_type: any :ivar service_principal_credential: The credential of the service principal object in Azure Active Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey', servicePrincipalCredential can be SecureString or AzureKeyVaultSecretReference. If @@ -21186,7 +21431,7 @@ class DynamicsLinkedService(LinkedService): 'username': {'key': 'typeProperties.username', 'type': 'object'}, 'password': {'key': 'typeProperties.password', 'type': 'SecretBase'}, 'service_principal_id': {'key': 'typeProperties.servicePrincipalId', 'type': 'object'}, - 'service_principal_credential_type': {'key': 'typeProperties.servicePrincipalCredentialType', 'type': 'str'}, + 'service_principal_credential_type': {'key': 'typeProperties.servicePrincipalCredentialType', 'type': 'object'}, 'service_principal_credential': {'key': 'typeProperties.servicePrincipalCredential', 'type': 'SecretBase'}, 'encrypted_credential': {'key': 'typeProperties.encryptedCredential', 'type': 'object'}, 'credential': {'key': 'typeProperties.credential', 'type': 'CredentialReference'}, @@ -21209,7 +21454,7 @@ def __init__( username: Optional[Any] = None, password: Optional["SecretBase"] = None, service_principal_id: Optional[Any] = None, - service_principal_credential_type: Optional[str] = None, + service_principal_credential_type: Optional[Any] = None, service_principal_credential: Optional["SecretBase"] = None, encrypted_credential: Optional[Any] = None, credential: Optional["CredentialReference"] = None, @@ -21261,7 +21506,7 @@ def __init__( :keyword service_principal_credential_type: The service principal credential type to use in Server-To-Server authentication. 'ServicePrincipalKey' for key/secret, 'ServicePrincipalCert' for certificate. Type: string (or Expression with resultType string). - :paramtype service_principal_credential_type: str + :paramtype service_principal_credential_type: any :keyword service_principal_credential: The credential of the service principal object in Azure Active Directory. If servicePrincipalCredentialType is 'ServicePrincipalKey', servicePrincipalCredential can be SecureString or AzureKeyVaultSecretReference. If @@ -22437,6 +22682,8 @@ class ExecutePipelineActivity(ControlActivity): :vartype depends_on: list[~azure.mgmt.datafactory.models.ActivityDependency] :ivar user_properties: Activity user properties. :vartype user_properties: list[~azure.mgmt.datafactory.models.UserProperty] + :ivar policy: Execute pipeline activity policy. + :vartype policy: ~azure.mgmt.datafactory.models.ExecutePipelineActivityPolicy :ivar pipeline: Required. Pipeline reference. :vartype pipeline: ~azure.mgmt.datafactory.models.PipelineReference :ivar parameters: Pipeline parameters. @@ -22459,6 +22706,7 @@ class ExecutePipelineActivity(ControlActivity): 'description': {'key': 'description', 'type': 'str'}, 'depends_on': {'key': 'dependsOn', 'type': '[ActivityDependency]'}, 'user_properties': {'key': 'userProperties', 'type': '[UserProperty]'}, + 'policy': {'key': 'policy', 'type': 'ExecutePipelineActivityPolicy'}, 'pipeline': {'key': 'typeProperties.pipeline', 'type': 'PipelineReference'}, 'parameters': {'key': 'typeProperties.parameters', 'type': '{object}'}, 'wait_on_completion': {'key': 'typeProperties.waitOnCompletion', 'type': 'bool'}, @@ -22473,6 +22721,7 @@ def __init__( description: Optional[str] = None, depends_on: Optional[List["ActivityDependency"]] = None, user_properties: Optional[List["UserProperty"]] = None, + policy: Optional["ExecutePipelineActivityPolicy"] = None, parameters: Optional[Dict[str, Any]] = None, wait_on_completion: Optional[bool] = None, **kwargs @@ -22489,6 +22738,8 @@ def __init__( :paramtype depends_on: list[~azure.mgmt.datafactory.models.ActivityDependency] :keyword user_properties: Activity user properties. :paramtype user_properties: list[~azure.mgmt.datafactory.models.UserProperty] + :keyword policy: Execute pipeline activity policy. + :paramtype policy: ~azure.mgmt.datafactory.models.ExecutePipelineActivityPolicy :keyword pipeline: Required. Pipeline reference. :paramtype pipeline: ~azure.mgmt.datafactory.models.PipelineReference :keyword parameters: Pipeline parameters. @@ -22499,11 +22750,48 @@ def __init__( """ super(ExecutePipelineActivity, self).__init__(additional_properties=additional_properties, name=name, description=description, depends_on=depends_on, user_properties=user_properties, **kwargs) self.type = 'ExecutePipeline' # type: str + self.policy = policy self.pipeline = pipeline self.parameters = parameters self.wait_on_completion = wait_on_completion +class ExecutePipelineActivityPolicy(msrest.serialization.Model): + """Execution policy for an execute pipeline activity. + + :ivar additional_properties: Unmatched properties from the message are deserialized to this + collection. + :vartype additional_properties: dict[str, any] + :ivar secure_input: When set to true, Input from activity is considered as secure and will not + be logged to monitoring. + :vartype secure_input: bool + """ + + _attribute_map = { + 'additional_properties': {'key': '', 'type': '{object}'}, + 'secure_input': {'key': 'secureInput', 'type': 'bool'}, + } + + def __init__( + self, + *, + additional_properties: Optional[Dict[str, Any]] = None, + secure_input: Optional[bool] = None, + **kwargs + ): + """ + :keyword additional_properties: Unmatched properties from the message are deserialized to this + collection. + :paramtype additional_properties: dict[str, any] + :keyword secure_input: When set to true, Input from activity is considered as secure and will + not be logged to monitoring. + :paramtype secure_input: bool + """ + super(ExecutePipelineActivityPolicy, self).__init__(**kwargs) + self.additional_properties = additional_properties + self.secure_input = secure_input + + class ExecutePowerQueryActivityTypeProperties(ExecuteDataFlowActivityTypeProperties): """Execute power query data flow activity properties. @@ -34251,19 +34539,17 @@ def __init__( class ManagedVirtualNetworkReference(msrest.serialization.Model): """Managed Virtual Network reference type. - Variables are only populated by the server, and will be ignored when sending a request. - All required parameters must be populated in order to send to Azure. - :ivar type: Managed Virtual Network reference type. Has constant value: + :ivar type: Required. Managed Virtual Network reference type. Possible values include: "ManagedVirtualNetworkReference". - :vartype type: str + :vartype type: str or ~azure.mgmt.datafactory.models.ManagedVirtualNetworkReferenceType :ivar reference_name: Required. Reference ManagedVirtualNetwork name. :vartype reference_name: str """ _validation = { - 'type': {'required': True, 'constant': True}, + 'type': {'required': True}, 'reference_name': {'required': True}, } @@ -34272,19 +34558,22 @@ class ManagedVirtualNetworkReference(msrest.serialization.Model): 'reference_name': {'key': 'referenceName', 'type': 'str'}, } - type = "ManagedVirtualNetworkReference" - def __init__( self, *, + type: Union[str, "ManagedVirtualNetworkReferenceType"], reference_name: str, **kwargs ): """ + :keyword type: Required. Managed Virtual Network reference type. Possible values include: + "ManagedVirtualNetworkReference". + :paramtype type: str or ~azure.mgmt.datafactory.models.ManagedVirtualNetworkReferenceType :keyword reference_name: Required. Reference ManagedVirtualNetwork name. :paramtype reference_name: str """ super(ManagedVirtualNetworkReference, self).__init__(**kwargs) + self.type = type self.reference_name = reference_name @@ -48689,7 +48978,7 @@ class ScriptAction(msrest.serialization.Model): :ivar uri: Required. The URI for the script action. :vartype uri: str :ivar roles: Required. The node types on which the script action should be executed. - :vartype roles: str + :vartype roles: any :ivar parameters: The parameters for the script action. :vartype parameters: str """ @@ -48703,7 +48992,7 @@ class ScriptAction(msrest.serialization.Model): _attribute_map = { 'name': {'key': 'name', 'type': 'str'}, 'uri': {'key': 'uri', 'type': 'str'}, - 'roles': {'key': 'roles', 'type': 'str'}, + 'roles': {'key': 'roles', 'type': 'object'}, 'parameters': {'key': 'parameters', 'type': 'str'}, } @@ -48712,7 +49001,7 @@ def __init__( *, name: str, uri: str, - roles: str, + roles: Any, parameters: Optional[str] = None, **kwargs ): @@ -48722,7 +49011,7 @@ def __init__( :keyword uri: Required. The URI for the script action. :paramtype uri: str :keyword roles: Required. The node types on which the script action should be executed. - :paramtype roles: str + :paramtype roles: any :keyword parameters: The parameters for the script action. :paramtype parameters: str """ @@ -53082,8 +53371,7 @@ class SqlServerStoredProcedureActivity(ExecutionActivity): :vartype stored_procedure_name: any :ivar stored_procedure_parameters: Value and type setting for stored procedure parameters. Example: "{Parameter1: {value: "1", type: "int"}}". - :vartype stored_procedure_parameters: dict[str, - ~azure.mgmt.datafactory.models.StoredProcedureParameter] + :vartype stored_procedure_parameters: any """ _validation = { @@ -53102,7 +53390,7 @@ class SqlServerStoredProcedureActivity(ExecutionActivity): 'linked_service_name': {'key': 'linkedServiceName', 'type': 'LinkedServiceReference'}, 'policy': {'key': 'policy', 'type': 'ActivityPolicy'}, 'stored_procedure_name': {'key': 'typeProperties.storedProcedureName', 'type': 'object'}, - 'stored_procedure_parameters': {'key': 'typeProperties.storedProcedureParameters', 'type': '{StoredProcedureParameter}'}, + 'stored_procedure_parameters': {'key': 'typeProperties.storedProcedureParameters', 'type': 'object'}, } def __init__( @@ -53116,7 +53404,7 @@ def __init__( user_properties: Optional[List["UserProperty"]] = None, linked_service_name: Optional["LinkedServiceReference"] = None, policy: Optional["ActivityPolicy"] = None, - stored_procedure_parameters: Optional[Dict[str, "StoredProcedureParameter"]] = None, + stored_procedure_parameters: Optional[Any] = None, **kwargs ): """ @@ -53140,8 +53428,7 @@ def __init__( :paramtype stored_procedure_name: any :keyword stored_procedure_parameters: Value and type setting for stored procedure parameters. Example: "{Parameter1: {value: "1", type: "int"}}". - :paramtype stored_procedure_parameters: dict[str, - ~azure.mgmt.datafactory.models.StoredProcedureParameter] + :paramtype stored_procedure_parameters: any """ super(SqlServerStoredProcedureActivity, self).__init__(additional_properties=additional_properties, name=name, description=description, depends_on=depends_on, user_properties=user_properties, linked_service_name=linked_service_name, policy=policy, **kwargs) self.type = 'SqlServerStoredProcedure' # type: str @@ -56457,18 +56744,16 @@ def __init__( class TriggerReference(msrest.serialization.Model): """Trigger reference type. - Variables are only populated by the server, and will be ignored when sending a request. - All required parameters must be populated in order to send to Azure. - :ivar type: Trigger reference type. Has constant value: "TriggerReference". - :vartype type: str + :ivar type: Required. Trigger reference type. Possible values include: "TriggerReference". + :vartype type: str or ~azure.mgmt.datafactory.models.TriggerReferenceType :ivar reference_name: Required. Reference trigger name. :vartype reference_name: str """ _validation = { - 'type': {'required': True, 'constant': True}, + 'type': {'required': True}, 'reference_name': {'required': True}, } @@ -56477,19 +56762,21 @@ class TriggerReference(msrest.serialization.Model): 'reference_name': {'key': 'referenceName', 'type': 'str'}, } - type = "TriggerReference" - def __init__( self, *, + type: Union[str, "TriggerReferenceType"], reference_name: str, **kwargs ): """ + :keyword type: Required. Trigger reference type. Possible values include: "TriggerReference". + :paramtype type: str or ~azure.mgmt.datafactory.models.TriggerReferenceType :keyword reference_name: Required. Reference trigger name. :paramtype reference_name: str """ super(TriggerReference, self).__init__(**kwargs) + self.type = type self.reference_name = reference_name @@ -56894,6 +57181,82 @@ def __init__( self.size = size +class TwilioLinkedService(LinkedService): + """Linked service for Twilio. + + All required parameters must be populated in order to send to Azure. + + :ivar additional_properties: Unmatched properties from the message are deserialized to this + collection. + :vartype additional_properties: dict[str, any] + :ivar type: Required. Type of linked service.Constant filled by server. + :vartype type: str + :ivar connect_via: The integration runtime reference. + :vartype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :ivar description: Linked service description. + :vartype description: str + :ivar parameters: Parameters for linked service. + :vartype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :ivar annotations: List of tags that can be used for describing the linked service. + :vartype annotations: list[any] + :ivar user_name: Required. The Account SID of Twilio service. + :vartype user_name: any + :ivar password: Required. The auth token of Twilio service. + :vartype password: ~azure.mgmt.datafactory.models.SecretBase + """ + + _validation = { + 'type': {'required': True}, + 'user_name': {'required': True}, + 'password': {'required': True}, + } + + _attribute_map = { + 'additional_properties': {'key': '', 'type': '{object}'}, + 'type': {'key': 'type', 'type': 'str'}, + 'connect_via': {'key': 'connectVia', 'type': 'IntegrationRuntimeReference'}, + 'description': {'key': 'description', 'type': 'str'}, + 'parameters': {'key': 'parameters', 'type': '{ParameterSpecification}'}, + 'annotations': {'key': 'annotations', 'type': '[object]'}, + 'user_name': {'key': 'typeProperties.userName', 'type': 'object'}, + 'password': {'key': 'typeProperties.password', 'type': 'SecretBase'}, + } + + def __init__( + self, + *, + user_name: Any, + password: "SecretBase", + additional_properties: Optional[Dict[str, Any]] = None, + connect_via: Optional["IntegrationRuntimeReference"] = None, + description: Optional[str] = None, + parameters: Optional[Dict[str, "ParameterSpecification"]] = None, + annotations: Optional[List[Any]] = None, + **kwargs + ): + """ + :keyword additional_properties: Unmatched properties from the message are deserialized to this + collection. + :paramtype additional_properties: dict[str, any] + :keyword connect_via: The integration runtime reference. + :paramtype connect_via: ~azure.mgmt.datafactory.models.IntegrationRuntimeReference + :keyword description: Linked service description. + :paramtype description: str + :keyword parameters: Parameters for linked service. + :paramtype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] + :keyword annotations: List of tags that can be used for describing the linked service. + :paramtype annotations: list[any] + :keyword user_name: Required. The Account SID of Twilio service. + :paramtype user_name: any + :keyword password: Required. The auth token of Twilio service. + :paramtype password: ~azure.mgmt.datafactory.models.SecretBase + """ + super(TwilioLinkedService, self).__init__(additional_properties=additional_properties, connect_via=connect_via, description=description, parameters=parameters, annotations=annotations, **kwargs) + self.type = 'Twilio' # type: str + self.user_name = user_name + self.password = password + + class TypeConversionSettings(msrest.serialization.Model): """Type conversion settings. @@ -57778,6 +58141,8 @@ class WebActivity(ExecutionActivity): :vartype body: any :ivar authentication: Authentication method used for calling the endpoint. :vartype authentication: ~azure.mgmt.datafactory.models.WebActivityAuthentication + :ivar disable_cert_validation: When set to true, Certificate validation will be disabled. + :vartype disable_cert_validation: bool :ivar datasets: List of datasets passed to web endpoint. :vartype datasets: list[~azure.mgmt.datafactory.models.DatasetReference] :ivar linked_services: List of linked services passed to web endpoint. @@ -57807,6 +58172,7 @@ class WebActivity(ExecutionActivity): 'headers': {'key': 'typeProperties.headers', 'type': 'object'}, 'body': {'key': 'typeProperties.body', 'type': 'object'}, 'authentication': {'key': 'typeProperties.authentication', 'type': 'WebActivityAuthentication'}, + 'disable_cert_validation': {'key': 'typeProperties.disableCertValidation', 'type': 'bool'}, 'datasets': {'key': 'typeProperties.datasets', 'type': '[DatasetReference]'}, 'linked_services': {'key': 'typeProperties.linkedServices', 'type': '[LinkedServiceReference]'}, 'connect_via': {'key': 'typeProperties.connectVia', 'type': 'IntegrationRuntimeReference'}, @@ -57827,6 +58193,7 @@ def __init__( headers: Optional[Any] = None, body: Optional[Any] = None, authentication: Optional["WebActivityAuthentication"] = None, + disable_cert_validation: Optional[bool] = None, datasets: Optional[List["DatasetReference"]] = None, linked_services: Optional[List["LinkedServiceReference"]] = None, connect_via: Optional["IntegrationRuntimeReference"] = None, @@ -57863,6 +58230,8 @@ def __init__( :paramtype body: any :keyword authentication: Authentication method used for calling the endpoint. :paramtype authentication: ~azure.mgmt.datafactory.models.WebActivityAuthentication + :keyword disable_cert_validation: When set to true, Certificate validation will be disabled. + :paramtype disable_cert_validation: bool :keyword datasets: List of datasets passed to web endpoint. :paramtype datasets: list[~azure.mgmt.datafactory.models.DatasetReference] :keyword linked_services: List of linked services passed to web endpoint. @@ -57877,6 +58246,7 @@ def __init__( self.headers = headers self.body = body self.authentication = authentication + self.disable_cert_validation = disable_cert_validation self.datasets = datasets self.linked_services = linked_services self.connect_via = connect_via