diff --git a/setup.py b/setup.py index 24d6181..ac5f129 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ name="ctm-python-client", packages=find_packages(where="src"), package_dir={"": "src"}, - version="2.5.6", + version="2.5.7", description="Python Workflows for Control-M", long_description=long_description, long_description_content_type='text/markdown', diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py index b85cd28..ff6b0fa 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -82,6 +82,22 @@ class ConnectionProfileAwsDynamoDB(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPDeploymentManager(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Manager URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureDevOps(ConnectionProfile): @@ -114,22 +130,6 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileGCPDeploymentManager(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Manager URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsEC2(ConnectionProfile): @@ -276,6 +276,24 @@ class ConnectionProfileGCPDataFusion(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileUIPath(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Name'}) + tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Url'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + app_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App Secret'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileDatadog(ConnectionProfile): @@ -298,24 +316,6 @@ class ConnectionProfileDatadog(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileUIPath(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Name'}) - tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Url'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - app_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App Secret'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsGlue(ConnectionProfile): @@ -398,32 +398,6 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsAppFlow(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS AppFlow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS AppFlow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_appflow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Appflow URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access key ID'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role ARN'}) - assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role Session'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureBatchAccounts(ConnectionProfile): @@ -460,6 +434,32 @@ class ConnectionProfileAzureBatchAccounts(ConnectionProfile): '_aapi_repr_': 'Rerun Attempts'}) +@attrs.define +class ConnectionProfileAwsAppFlow(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS AppFlow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS AppFlow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_appflow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Appflow URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access key ID'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureFunctions(ConnectionProfile): @@ -536,38 +536,6 @@ class ConnectionProfileTableau(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileGCPDataplex(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP Dataplex URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection timeout'}) - - -@attrs.define -class ConnectionProfileGCPComposer(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - composer_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Composer URL'}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureVM(ConnectionProfile): @@ -602,6 +570,38 @@ class ConnectionProfileAzureVM(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileGCPDataplex(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Dataplex URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection timeout'}) + + +@attrs.define +class ConnectionProfileGCPComposer(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + composer_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Composer URL'}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileApacheNiFi(ConnectionProfile): @@ -678,6 +678,32 @@ class ConnectionProfileGCPDataflow(ConnectionProfile): '_aapi_repr_': 'Service Account Key'}) +@attrs.define +class ConnectionProfileAwsMWAA(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS MWAA', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS MWAA'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_m_w_a_a_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS MWAA URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsBedrock(ConnectionProfile): @@ -711,27 +737,27 @@ class ConnectionProfileAwsBedrock(ConnectionProfile): @attrs.define -class ConnectionProfileAwsMWAA(ConnectionProfile): +class ConnectionProfileVeritasNetBackup(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS MWAA', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS MWAA'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Veritas NetBackup', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Veritas NetBackup'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_m_w_a_a_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS MWAA URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) - assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role ARN'}) - assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role Session'}) + master_server_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Master Server Name'}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) + domain_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Domain Type'}) + domain_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Domain Name'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1109,35 +1135,35 @@ class ConnectionProfileAutomationAnywhere(ConnectionProfile): @attrs.define -class ConnectionProfileJenkins(ConnectionProfile): +class ConnectionProfileRabbitMQ(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Jenkins'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - jenkins_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Jenkins URL'}) + rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RabbitMQ URL'}) + port: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Port'}) username: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Username'}) - user_api_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User API Token'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @attrs.define -class ConnectionProfileRabbitMQ(ConnectionProfile): +class ConnectionProfileJenkins(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:RabbitMQ', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Jenkins'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'RabbitMQ URL'}) - port: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Port'}) + jenkins_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Jenkins URL'}) username: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) + user_api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User API Token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1222,6 +1248,26 @@ class ConnectionProfileVeeamBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Name'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + + @attrs.define class ConnectionProfileAzureBackup(ConnectionProfile): @@ -1250,26 +1296,6 @@ class ConnectionProfileAzureBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - user_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Name'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) - - @attrs.define class ConnectionProfileSnowflake(ConnectionProfile): @@ -1328,32 +1354,6 @@ class ConnectionProfileMicrosoftPowerBISP(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Database Migration Service', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Database Migration Service'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_d_m_s_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS DMS URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role ARN'}) - assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role Session'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileMicroFocusWindows(ConnectionProfile): @@ -1380,6 +1380,32 @@ class ConnectionProfileMicroFocusWindows(ConnectionProfile): '_aapi_repr_': 'RunAs-Pass'}) +@attrs.define +class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Database Migration Service', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Database Migration Service'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_d_m_s_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS DMS URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileIBMDataStageLinux(ConnectionProfile): @@ -1663,6 +1689,40 @@ class ConnectionProfileAtlassianJira(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureAppServicesWebJobs(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure App Services WebJobs', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure App Services WebJobs'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Subscription ID'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) + specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Specify Managed Identity Client ID'}) + managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Managed Identity Client ID'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Login URL'}) + management_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Management URL'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + + @attrs.define class ConnectionProfileCircleCI(ConnectionProfile): @@ -1898,32 +1958,6 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsSQS(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS SQS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS SQS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_sqs_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS SQS URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) - assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role ARN'}) - assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role Session'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileIBMDataStageWindows(ConnectionProfile): @@ -1970,6 +2004,32 @@ class ConnectionProfileSnowflakeIdP(ConnectionProfile): '_aapi_repr_': 'Scope'}) +@attrs.define +class ConnectionProfileAwsSQS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS SQS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS SQS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_sqs_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS SQS URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPDataprep(ConnectionProfile): @@ -2082,6 +2142,20 @@ class ConnectionProfileAwsAthena(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileFivetran(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fivetran Base URL'}) + api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Base 64 Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureServiceBus(ConnectionProfile): @@ -2110,20 +2184,6 @@ class ConnectionProfileAzureServiceBus(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileFivetran(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fivetran Base URL'}) - api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Base 64 Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -2356,6 +2416,23 @@ class ConnectionProfileTerraform(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) + +@attrs.define +class ConnectionProfileGCPFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + gcp_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP API URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAtlassianBitbucket(ConnectionProfile): @@ -2381,17 +2458,35 @@ class ConnectionProfileAtlassianBitbucket(ConnectionProfile): @attrs.define -class ConnectionProfileGCPFunctions(ConnectionProfile): +class ConnectionProfileAzureLogicApps(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Functions'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Logic Apps', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Logic Apps'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - gcp_api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP API URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) + subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Subscription ID'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Specify Managed Identity Client ID'}) + managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Managed Identity Client ID'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Login URL'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -2442,28 +2537,6 @@ class ConnectionProfileOCIVM(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsDataPipeline(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Pipeline URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileOCIDataIntegration(ConnectionProfile): @@ -2492,6 +2565,28 @@ class ConnectionProfileOCIDataIntegration(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsDataPipeline(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Pipeline URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPCloudRun(ConnectionProfile): @@ -2506,97 +2601,3 @@ class ConnectionProfileGCPCloudRun(ConnectionProfile): '_aapi_repr_': 'Service Account Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) - - -@attrs.define -class ConnectionProfileVeritasNetBackup(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Veritas NetBackup', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Veritas NetBackup'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - master_server_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Master Server Name'}) - endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Endpoint URL'}) - authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Type'}) - domain_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Domain Type'}) - domain_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Domain Name'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - api_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - -@attrs.define -class ConnectionProfileAzureAppServicesWebJobs(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure App Services WebJobs', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure App Services WebJobs'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Type'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Login URL'}) - management_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Management URL'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - http_codes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'HTTP Codes'}) - rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Interval'}) - attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Attempt Reruns'}) - - -@attrs.define -class ConnectionProfileAzureLogicApps(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Logic Apps', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Logic Apps'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login URL'}) - http_codes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'HTTP Codes'}) - rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Interval'}) - attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Attempt Reruns'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index e92cbb9..00d3ffb 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -108,6 +108,28 @@ class JobAwsDynamoDB(Job): '_aapi_repr_': 'Failure Tolarance '}) +@attrs.define +class JobGCPDeploymentManager(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Name'}) + yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Yaml Config Content'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAzureDevOps(Job): @@ -138,28 +160,6 @@ class JobAzureDevOps(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobGCPDeploymentManager(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Name'}) - yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Yaml Config Content'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsEC2(Job): @@ -362,6 +362,30 @@ class JobGCPDataFusion(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobUIPath(Job): + + _type: str = attrs.field(init=False, default='Job:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + folder_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Name'}) + folder_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Id'}) + process_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Process Name'}) + robot_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Robot Name'}) + robot_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Robot Id'}) + optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Input Parameters'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobDatadog(Job): @@ -394,30 +418,6 @@ class JobDatadog(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobUIPath(Job): - - _type: str = attrs.field(init=False, default='Job:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - folder_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Name'}) - folder_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Id'}) - process_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Process Name'}) - robot_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Name'}) - robot_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Id'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobAwsGlue(Job): @@ -480,6 +480,10 @@ class JobApacheAirflow(Job): '_aapi_repr_': 'URL Request Path'}) json: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'JSON'}) + switch_to_rerun: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Switch To Rerun'}) + keep_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Keep Run ID'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -518,32 +522,6 @@ class JobAwsCloudFormation(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsAppFlow(Job): - - _type: str = attrs.field(init=False, default='Job:AWS AppFlow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS AppFlow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) - flow_name__iam: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name - IAM'}) - flow_name__assume_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name - Assume Role'}) - trigger_flow_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trigger Flow with Idempotency Token'}) - client_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Token'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureBatchAccounts(Job): @@ -584,6 +562,32 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) +@attrs.define +class JobAwsAppFlow(Job): + + _type: str = attrs.field(init=False, default='Job:AWS AppFlow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS AppFlow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + flow_name__iam: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name - IAM'}) + flow_name__assume_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name - Assume Role'}) + trigger_flow_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Flow with Idempotency Token'}) + client_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Token'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAzureFunctions(Job): @@ -660,6 +664,36 @@ class JobTableau(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureVM(Job): + + _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + vm_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'VM Name'}) + operation: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Operation'}) + tag_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Name'}) + tag_value: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Value'}) + input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Parameters'}) + verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Interval'}) + delete_vm_os_disk: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delete VM OS Disk'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) + + @attrs.define class JobGCPDataplex(Job): @@ -712,36 +746,6 @@ class JobGCPComposer(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureVM(Job): - - _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - vm_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'VM Name'}) - operation: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Operation'}) - tag_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tag Name'}) - tag_value: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tag Value'}) - input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Input Parameters'}) - verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Interval'}) - delete_vm_os_disk: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delete VM OS Disk'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) - api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API-VERSION'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) - - @attrs.define class JobApacheNiFi(Job): @@ -868,6 +872,32 @@ class JobGCPDataflow(Job): '_aapi_repr_': 'Log Level'}) +@attrs.define +class JobAwsMWAA(Job): + + _type: str = attrs.field(init=False, default='Job:AWS MWAA', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS MWAA'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + m_w_a_a_environment_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MWAA Environment Name'}) + d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Name'}) + d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Run ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + only_failed: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Only Failed'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsBedrock(Job): @@ -899,35 +929,51 @@ class JobAwsBedrock(Job): @attrs.define -class JobAwsMWAA(Job): +class JobVeritasNetBackup(Job): - _type: str = attrs.field(init=False, default='Job:AWS MWAA', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS MWAA'}) + _type: str = attrs.field(init=False, default='Job:Veritas NetBackup', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Veritas NetBackup'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) action: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Action'}) - m_w_a_a_environment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'MWAA Environment Name'}) - d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Name'}) - d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Run ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - only_failed: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Only Failed'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - -@attrs.define -class JobMatillion(Job): - - _type: str = attrs.field(init=False, default='Job:Matillion', metadata={ + json_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'JSON Parameters'}) + create_jobs_per_client: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Create Jobs Per Client'}) + policy_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Policy Name'}) + client_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Name'}) + schedule_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Schedule Name'}) + keyword: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Keyword'}) + instance_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Instance Name'}) + database_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Database Name'}) + db_unique_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DB Unique Name'}) + db_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DB ID'}) + trial_backup: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trial Backup'}) + output__management: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output Management'}) + restart_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Restart Job ID'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + +@attrs.define +class JobMatillion(Job): + + _type: str = attrs.field(init=False, default='Job:Matillion', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Matillion'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1238,6 +1284,10 @@ class JobBoomiAtomsphere(Job): '_aapi_repr_': 'Polling Interval Frequency'}) tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Tolerance'}) + use_advanced_json_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Use Advanced JSON Format'}) + json_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'JSON Format'}) @attrs.define @@ -1390,30 +1440,6 @@ class JobAutomationAnywhere(Job): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class JobJenkins(Job): - - _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Parameters'}) - parameters: typing.List[str] = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) - add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Branch Name'}) - branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Branch Name'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobRabbitMQ(Job): @@ -1440,6 +1466,32 @@ class JobRabbitMQ(Job): '_aapi_repr_': 'Queue'}) +@attrs.define +class JobJenkins(Job): + + _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Parameters'}) + parameters: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) + add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Branch Name'}) + branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Branch Name'}) + fetch_console_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fetch Console Logs'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobMicrosoftFabric(Job): @@ -1522,6 +1574,32 @@ class JobVeeamBackup(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobMicrosoftPowerBI(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) + workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace Name'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + + @attrs.define class JobAzureBackup(Job): @@ -1560,32 +1638,6 @@ class JobAzureBackup(Job): '_aapi_repr_': 'Failure Tolerance '}) -@attrs.define -class JobMicrosoftPowerBI(Job): - - _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) - dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - - @attrs.define class JobSnowflake(Job): @@ -1706,30 +1758,6 @@ class JobMicrosoftPowerBISP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsDatabaseMigrationService(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Database Migration Service', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Database Migration Service'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - data_migration_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Migration ARN'}) - start_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Start Type'}) - database_migration_task_arn: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Database Migration Task ARN'}) - output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Output Job Logs'}) - failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance '}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobMicroFocusWindows(Job): @@ -1772,6 +1800,30 @@ class JobMicroFocusWindows(Job): kw_only=True, default=None, metadata={'_aapi_repr_': 'Modified JCL Path and Filename'}) +@attrs.define +class JobAwsDatabaseMigrationService(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Database Migration Service', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Database Migration Service'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + data_migration_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Migration ARN'}) + start_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Start Type'}) + database_migration_task_arn: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Database Migration Task ARN'}) + output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output Job Logs'}) + failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance '}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobIBMDataStageLinux(Job): @@ -2108,6 +2160,32 @@ class JobAtlassianJira(Job): '_aapi_repr_': 'Comment'}) +@attrs.define +class JobAzureAppServicesWebJobs(Job): + + _type: str = attrs.field(init=False, default='Job:Azure App Services WebJobs', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure App Services WebJobs'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + resource_group_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group Name'}) + web_app_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Web App Name'}) + web_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Web Job Name'}) + slot: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Slot'}) + show_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Output'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobCircleCI(Job): @@ -2328,43 +2406,6 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobAwsSQS(Job): - - _type: str = attrs.field(init=False, default='Job:AWS SQS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS SQS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action Type'}) - queue_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - queue_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue URL'}) - message_body: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Body'}) - delay_seconds: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delay Seconds'}) - message_deduplication_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Deduplication ID'}) - message_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Group ID'}) - message_attributes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Attributes'}) - attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) - attribute1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) - attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) - attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) - attribute2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) - attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) - attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) - attribute3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) - attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) - - @attrs.define class JobIBMDataStageWindows(Job): @@ -2488,11 +2529,48 @@ class JobSnowflakeIdP(Job): @attrs.define -class JobGCPDataprep(Job): +class JobAwsSQS(Job): - _type: str = attrs.field(init=False, default='Job:GCP Dataprep', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataprep'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) + _type: str = attrs.field(init=False, default='Job:AWS SQS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS SQS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action Type'}) + queue_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + queue_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue URL'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) + delay_seconds: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delay Seconds'}) + message_deduplication_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Deduplication ID'}) + message_group_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Group ID'}) + message_attributes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Attributes'}) + attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) + attribute1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) + attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) + attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) + attribute2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) + attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) + attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) + attribute3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) + attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) + + +@attrs.define +class JobGCPDataprep(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Dataprep', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataprep'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) flow_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2625,23 +2703,6 @@ class JobAwsAthena(Job): '_aapi_repr_': 'NoPerm'}) -@attrs.define -class JobAzureServiceBus(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Bus Namespace'}) - queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) - message_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Format'}) - message_body: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Body'}) - - @attrs.define class JobFivetran(Job): @@ -2666,6 +2727,23 @@ class JobFivetran(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureServiceBus(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Bus Namespace'}) + queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) + message_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Format'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) + + @attrs.define class JobAwsBatch(Job): @@ -3024,6 +3102,37 @@ class JobTerraform(Job): '_aapi_repr_': 'Failure Tolerance'}) + +@attrs.define +class JobGCPFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Location'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + function_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Parameters'}) + url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'URL Parameters'}) + body: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Body'}) + api_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Version'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) + + @attrs.define class JobAtlassianBitbucket(Job): @@ -3099,33 +3208,33 @@ class JobAtlassianBitbucket(Job): @attrs.define -class JobGCPFunctions(Job): +class JobAzureLogicApps(Job): - _type: str = attrs.field(init=False, default='Job:GCP Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Functions'}) + _type: str = attrs.field(init=False, default='Job:Azure Logic Apps', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Logic Apps'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Location'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - function_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Parameters'}) - url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'URL Parameters'}) - body: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Body'}) - api_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Version'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) + plan: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Plan'}) + logic_app_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Logic App Name'}) + workflow: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) get_logs: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Get Logs'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + resubmit_action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resubmit Action'}) + failed_action_to_resubmit: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failed Action to Resubmit'}) + t_r_a_c_k_i_n_g_r_u_n_id_r_e_r_u_n: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'TRACKING RUNID RERUN'}) @attrs.define @@ -3168,32 +3277,6 @@ class JobOCIVM(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsDataPipeline(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Data Pipeline'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - pipeline_unique_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Unique ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - trigger_created_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trigger Created Pipeline'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobOCIDataIntegration(Job): @@ -3221,87 +3304,25 @@ class JobOCIDataIntegration(Job): @attrs.define -class JobGCPCloudRun(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Cloud Run', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Cloud Run'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Location'}) - job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Name'}) - overrides_specification: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Overrides Specification'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - -@attrs.define -class JobVeritasNetBackup(Job): - - _type: str = attrs.field(init=False, default='Job:Veritas NetBackup', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Veritas NetBackup'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - json_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'JSON Parameters'}) - create_jobs_per_client: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Create Jobs Per Client'}) - policy_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Policy Name'}) - client_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Name'}) - schedule_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Schedule Name'}) - keyword: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Keyword'}) - instance_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Instance Name'}) - database_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Database Name'}) - db_unique_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DB Unique Name'}) - db_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DB ID'}) - trial_backup: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trial Backup'}) - output__management: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Output Management'}) - restart_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Restart Job ID'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - -@attrs.define -class JobAzureAppServicesWebJobs(Job): +class JobAwsDataPipeline(Job): - _type: str = attrs.field(init=False, default='Job:Azure App Services WebJobs', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure App Services WebJobs'}) + _type: str = attrs.field(init=False, default='Job:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Data Pipeline'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) action: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Action'}) - resource_group_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group Name'}) - web_app_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Web App Name'}) - web_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Web Job Name'}) - slot: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Slot'}) - show_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Output'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + pipeline_unique_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Unique ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + trigger_created_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Created Pipeline'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -3309,30 +3330,20 @@ class JobAzureAppServicesWebJobs(Job): @attrs.define -class JobAzureLogicApps(Job): +class JobGCPCloudRun(Job): - _type: str = attrs.field(init=False, default='Job:Azure Logic Apps', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Logic Apps'}) + _type: str = attrs.field(init=False, default='Job:GCP Cloud Run', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Cloud Run'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - plan: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Plan'}) - logic_app_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Logic App Name'}) - workflow: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workflow'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Location'}) + job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Name'}) + overrides_specification: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Overrides Specification'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) - resubmit_action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resubmit Action'}) - failed_action_to_resubmit: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failed Action to Resubmit'}) - t_r_a_c_k_i_n_g_r_u_n_id_r_e_r_u_n: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'TRACKING RUNID RERUN'}) diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 59f1bc5..bbb07dd 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.5.6' +__version__ = '2.5.7' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 088ffed..71fd799 100644 --- a/src/ctm_python_client/ext/autogen.py +++ b/src/ctm_python_client/ext/autogen.py @@ -8,7 +8,7 @@ __all__ = ['generate_ai_plugins_classes'] -IF_PLUGINS = ['GDR052023', 'TDM052022', 'ARS112024', 'AST072024', 'BAK092023', 'DTG052025', 'MFW022023', 'MBI042022', 'COM032023', 'ZRM082023', 'AEM072022', 'AEC082022', 'DSL122024', 'DTG022025', 'ACF082023', 'SNF092022', 'ICS032022', 'TER102023', 'AHD062022', 'NBU032025', 'ADM062025', 'ABB092025', 'ZML022023', 'GBQ102022', 'VBR062025', 'GBA032023', 'TDO042024', 'GDU102023', 'ABY122023', 'ADS102024', 'ZLA112022', 'MFL022023', 'ADY122023', 'GWF092023', 'SOP072023', 'MFB062025', 'TAB072023', 'ADO112023', 'RST062023', 'GDF032022', 'OVM012024', 'GLU062021', 'PDY092024', 'GEA072025', 'ADP122022', 'ASF012023', 'GCC052024', 'UIP072021', 'AMW112024', 'AAP092024', 'BEC032025', 'RBK072025', 'ZVM062022', 'QLC092022', 'ABR092025', 'ASQ032024', 'GDP042022', 'ZSY062022', 'AMM082023', 'BOO032022', 'ATR122022', 'ODS052024', 'GDQ112023', 'ZFN032022', 'MAT022025', 'ALM012024', 'ODI032024', 'DBX032022', 'RMQ082024', 'SFI122022', 'AAT052023', 'ABK042023', 'GFU012023', 'CMR022024', 'GVA092025', 'ANS032024', 'ASM0220223', 'ADF062021', 'NFI042024', 'DSW122024', 'ADB112022', 'ZDX112021', 'ZBA042022', 'ABA092022', 'APP022025', 'VNB032025', 'VMW102024', 'GVM062022', 'ASB012025', 'ZWB072025', 'CCI012025', 'GCR042024', 'DBT042023', 'SBT032025', 'JCP102025', 'GDM082023', 'GIT092025', 'ODF0420241', 'FVT032025', 'AWX122024', 'KBN062023', 'JEN022024', 'AAR072022', 'AAF112024', 'PBI082024', 'ACS042023', 'AQS012023'] +IF_PLUGINS = ['ADM062025', 'UIP072021', 'RST062023', 'GVM062022', 'GDF032022', 'GLU062021', 'ODI032024', 'BOO032022', 'OVM012024', 'ADS102024', 'AST072024', 'CCI012025', 'ATR122022', 'GIT092025', 'GDP042022', 'GCR042024', 'AAP092024', 'ICS032022', 'KBN062023', 'VBR062025', 'QLC092022', 'DSW122024', 'DTG022025', 'AAR072022', 'RMQ082024', 'GBQ102022', 'GDM082023', 'TDO042024', 'ACS042023', 'AMM082023', 'ABA092022', 'ZVM062022', 'ZBA042022', 'ODS052024', 'AQS012023', 'FVT032025', 'COM032023', 'TDM052022', 'ANS032024', 'RBK072025', 'BEC032025', 'AMW112024', 'AEC082022', 'CMR022024', 'ODF0420241', 'SFI122022', 'TAB072023', 'MFL022023', 'SOP072023', 'MFB062025', 'ADY122023', 'ABR092025', 'ARS112024', 'ZFN032022', 'SNF092022', 'ABY122023', 'ABK042023', 'APP022025', 'JEN022024', 'ASQ032024', 'ADF062021', 'AEM072022', 'NFI042024', 'DSL122024', 'ZLA112022', 'ABB092025', 'TER102023', 'SBT032025', 'AAF112024', 'AHD062022', 'ADP122022', 'GDR052023', 'ZDX112021', 'DTG052025', 'ZRM082023', 'ACF082023', 'AWX122024', 'MFW022023', 'ALM012024', 'PBI082024', 'GVA092025', 'DBX032022', 'JCP102025', 'GWF092023', 'MBI042022', 'GCC052024', 'GBA032023', 'ADO112023', 'VNB032025', 'BAK092023', 'ASF012023', 'ZWB072025', 'AAT052023', 'GDQ112023', 'GEA072025', 'DBT042023', 'ADB112022', 'VMW102024', 'MAT022025', 'GDU102023', 'ZML022023', 'NBU032025', 'ASM0220223', 'PDY092024', 'ZSY062022', 'ASB012025', 'GFU012023'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index fc0687e..dd7f56c 100644 --- a/tests/test_sanity.py +++ b/tests/test_sanity.py @@ -2,6 +2,6 @@ def test_version_author(): import ctm_python_client assert ctm_python_client.__author__ == 'BMC Software' - assert ctm_python_client.__version__ == '2.5.6' + assert ctm_python_client.__version__ == '2.5.7'