From 5b6634bcc73a24c0f07eebb0aa52aef74be610bb Mon Sep 17 00:00:00 2001 From: ybauming_bmcgit Date: Thu, 10 Jul 2025 01:47:38 +0300 Subject: [PATCH] WBL-328577 Control-M Integrations Factory up to July 2025 --- setup.py | 2 +- .../connection_profiles.py | 623 +++++++------- src/aapi/integration_factory/jobs.py | 805 +++++++++--------- src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/ext/autogen.py | 2 +- tests/test_sanity.py | 2 +- 6 files changed, 762 insertions(+), 674 deletions(-) diff --git a/setup.py b/setup.py index 7e8b4b2..cbff98e 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.2", + version="2.5.3", 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 d7ca1f2..12ddd4e 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -54,22 +54,6 @@ 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): @@ -88,6 +72,22 @@ 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): @@ -118,6 +118,28 @@ class ConnectionProfileAwsEC2(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileRubrik(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Rubrik', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Rubrik'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + rubrik_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rubrik URL'}) + client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client ID'}) + secret_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Secret Token'}) + 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'}) + + @attrs.define class ConnectionProfileAwsBackup(ConnectionProfile): @@ -212,24 +234,6 @@ 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): @@ -252,6 +256,24 @@ 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): @@ -320,6 +342,16 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_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'}) + 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'}) @@ -350,6 +382,36 @@ class ConnectionProfileAwsAppFlow(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureBatchAccounts(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Batch Accounts', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Batch Accounts'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + azure_ad_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure AD url'}) + 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'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + batch_resource_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch Resource url'}) + batch_account_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch Account Name'}) + batch_region_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch Region ID'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureFunctions(ConnectionProfile): @@ -382,36 +444,6 @@ class ConnectionProfileAzureFunctions(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureBatchAccounts(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Batch Accounts', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Batch Accounts'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - azure_ad_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure AD url'}) - 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'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - batch_resource_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Resource url'}) - batch_account_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Account Name'}) - batch_region_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Region ID'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsEMR(ConnectionProfile): @@ -454,6 +486,38 @@ class ConnectionProfileTableau(ConnectionProfile): '_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 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 ConnectionProfileAzureVM(ConnectionProfile): @@ -488,38 +552,6 @@ 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): @@ -644,20 +676,6 @@ class ConnectionProfileGCPDataproc(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileVMwareByBroadcom(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:VMware By Broadcom', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:VMware By Broadcom'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - 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'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureSynapse(ConnectionProfile): @@ -686,6 +704,20 @@ class ConnectionProfileAzureSynapse(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileVMwareByBroadcom(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:VMware By Broadcom', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:VMware By Broadcom'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + 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'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileCommunicationSuite(ConnectionProfile): @@ -750,32 +782,6 @@ class ConnectionProfileAzureMachineLearning(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileOCIDataFlow(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Data Flow URL'}) - oci_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User OCID'}) - tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenancy OCID'}) - fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fingerprint'}) - private_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Private Key'}) - config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Config File Path'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureDataFactory(ConnectionProfile): @@ -810,6 +816,32 @@ class ConnectionProfileAzureDataFactory(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileOCIDataFlow(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Data Flow URL'}) + oci_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User OCID'}) + tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenancy OCID'}) + fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fingerprint'}) + private_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Private Key'}) + config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Config File Path'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileWebServicesSOAP(ConnectionProfile): @@ -952,24 +984,6 @@ class ConnectionProfileAutomationAnywhere(ConnectionProfile): '_aapi_repr_': 'Password'}) -@attrs.define -class ConnectionProfileRabbitMQ(ConnectionProfile): - - _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}) - 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'}) - 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 ConnectionProfileJenkins(ConnectionProfile): @@ -987,27 +1001,19 @@ class ConnectionProfileJenkins(ConnectionProfile): @attrs.define -class ConnectionProfileVeeamBackup(ConnectionProfile): +class ConnectionProfileRabbitMQ(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Veeam Backup', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Veeam Backup'}) + _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}) - enterprise_manager_server: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Enterprise Manager Server'}) - url: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'URL'}) - api_supported_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Supported Version'}) + 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'}) password: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Password'}) - 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'}) @@ -1034,6 +1040,32 @@ class ConnectionProfileAwsRedshift(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileVeeamBackup(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Veeam Backup', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Veeam Backup'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + enterprise_manager_server: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Enterprise Manager Server'}) + url: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'URL'}) + api_supported_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Supported Version'}) + 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'}) + 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'}) + + @attrs.define class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): @@ -1134,26 +1166,6 @@ class ConnectionProfileMicrosoftPowerBISP(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileMicroFocusWindows(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Micro Focus Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Micro Focus Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - mfbsi_directory_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'MFBSI Directory Path'}) - mfbsi_config_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'MFBSI Config Path'}) - runtime_environment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Runtime Environment'}) - additional_micro_focus_settings_script: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Additional Micro Focus Settings Script'}) - run_as: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run As'}) - run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'RunAs-Pass'}) - - @attrs.define class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): @@ -1180,6 +1192,26 @@ class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicroFocusWindows(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Micro Focus Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Micro Focus Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + mfbsi_directory_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MFBSI Directory Path'}) + mfbsi_config_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MFBSI Config Path'}) + runtime_environment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Runtime Environment'}) + additional_micro_focus_settings_script: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Additional Micro Focus Settings Script'}) + run_as: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run As'}) + run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RunAs-Pass'}) + + @attrs.define class ConnectionProfileIBMDataStageLinux(ConnectionProfile): @@ -1401,6 +1433,22 @@ class ConnectionProfileTalendOAuth(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureHDInsight(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Name'}) + cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Username'}) + cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsQuickSight(ConnectionProfile): @@ -1425,22 +1473,6 @@ class ConnectionProfileAwsQuickSight(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureHDInsight(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Name'}) - cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Username'}) - cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileCircleCI(ConnectionProfile): @@ -1456,10 +1488,10 @@ class ConnectionProfileCircleCI(ConnectionProfile): @attrs.define -class ConnectionProfileAzureWebJobs(ConnectionProfile): +class ConnectionProfileAzureAppServicesWebJobs(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure WebJobs', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure WebJobs'}) + _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'}) @@ -1710,28 +1742,6 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileSnowflakeIdP(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Endpoint URL'}) - account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account Identifier'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - idp_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IDP URL'}) - scope: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Scope'}) - - @attrs.define class ConnectionProfileIBMDataStageWindows(ConnectionProfile): @@ -1782,6 +1792,28 @@ class ConnectionProfileAwsSQS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileSnowflakeIdP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Identifier'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + idp_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IDP URL'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + + @attrs.define class ConnectionProfileGCPDataprep(ConnectionProfile): @@ -1816,6 +1848,16 @@ class ConnectionProfileAwsGlueDataBrew(ConnectionProfile): '_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'}) + 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'}) @@ -1878,20 +1920,6 @@ class ConnectionProfileDBT(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): @@ -1920,6 +1948,20 @@ 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): @@ -2082,30 +2124,6 @@ class ConnectionProfileAzureResourceManager(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileInformaticaCS(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Login URL'}) - base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Base 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'}) - 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'}) - - @attrs.define class ConnectionProfileAwsStepFunctions(ConnectionProfile): @@ -2138,6 +2156,30 @@ class ConnectionProfileAwsStepFunctions(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileInformaticaCS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Login URL'}) + base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Base 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'}) + 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'}) + + @attrs.define class ConnectionProfileTerraform(ConnectionProfile): @@ -2152,7 +2194,6 @@ class ConnectionProfileTerraform(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) - @attrs.define class ConnectionProfileGCPFunctions(ConnectionProfile): @@ -2249,28 +2290,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): @@ -2299,6 +2318,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): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 258bb49..31cf295 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -74,28 +74,6 @@ 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): @@ -126,6 +104,28 @@ 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): @@ -168,6 +168,38 @@ class JobAwsEC2(Job): '_aapi_repr_': 'Get Instances logs'}) +@attrs.define +class JobRubrik(Job): + + _type: str = attrs.field(init=False, default='Job:Rubrik', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Rubrik'}) + 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'}) + s_l_a_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SLA ID'}) + vm_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'VM ID'}) + oracle_db_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Oracle DB ID'}) + n_a_s_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'NAS ID'}) + sql_db_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SQL DB ID'}) + delay_logs_retrieval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delay Logs Retrieval'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + year: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'YEAR'}) + month: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MONTH'}) + day: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'DAY'}) + + @attrs.define class JobAwsBackup(Job): @@ -296,30 +328,6 @@ 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): @@ -352,6 +360,30 @@ 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): @@ -390,6 +422,8 @@ class JobApacheAirflow(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) + airflow_rest_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Airflow REST Version'}) action: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Action'}) d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -398,8 +432,20 @@ class JobApacheAirflow(Job): '_aapi_repr_': 'DAG Run ID'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) + logical_date: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Logical Date'}) only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Only Failed Tasks'}) + include_subdags: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Include Subdags'}) + include_upstream: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Include Upstream'}) + include_downstream: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Include Downstream'}) + url_request_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'URL Request Path'}) + json: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'JSON'}) 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={ @@ -464,34 +510,6 @@ class JobAwsAppFlow(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_app: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App'}) - azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Resource'}) - azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Resource Scope'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - function_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Type'}) - verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Intervall'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API-VERSION'}) - - @attrs.define class JobAzureBatchAccounts(Job): @@ -532,6 +550,34 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) +@attrs.define +class JobAzureFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_app: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App'}) + azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource'}) + azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource Scope'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Input Parameters'}) + function_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Type'}) + verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Intervall'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) + + @attrs.define class JobAwsEMR(Job): @@ -581,33 +627,27 @@ class JobTableau(Job): @attrs.define -class JobAzureVM(Job): +class JobGCPComposer(Job): - _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) + _type: str = attrs.field(init=False, default='Job:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Composer'}) 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'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + 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_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Only Failed Tasks'}) + 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 @@ -637,27 +677,33 @@ class JobGCPDataplex(Job): @attrs.define -class JobGCPComposer(Job): +class JobAzureVM(Job): - _type: str = attrs.field(init=False, default='Job:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Composer'}) + _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'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - 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_tasks: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Only Failed Tasks'}) - 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'}) + 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 @@ -840,6 +886,22 @@ class JobGCPDataproc(Job): '_aapi_repr_': 'Interactive Session ID'}) +@attrs.define +class JobAzureSynapse(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Synapse', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Synapse'}) + 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'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + status_polling_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status polling interval'}) + + @attrs.define class JobVMwareByBroadcom(Job): @@ -906,22 +968,6 @@ class JobVMwareByBroadcom(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureSynapse(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Synapse', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Synapse'}) - 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'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - status_polling_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status polling interval'}) - - @attrs.define class JobCommunicationSuite(Job): @@ -974,24 +1020,6 @@ class JobAzureMachineLearning(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobOCIDataFlow(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Compartment OCID'}) - application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application OCID'}) - 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 JobAzureDataFactory(Job): @@ -1018,6 +1046,24 @@ class JobAzureDataFactory(Job): '_aapi_repr_': 'Reference Pipeline Run ID'}) +@attrs.define +class JobOCIDataFlow(Job): + + _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Compartment OCID'}) + application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application OCID'}) + 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 JobWebServicesSOAP(Job): @@ -1184,32 +1230,6 @@ class JobAutomationAnywhere(Job): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class JobRabbitMQ(Job): - - _type: str = attrs.field(init=False, default='Job:RabbitMQ', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:RabbitMQ'}) - 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'}) - vhost: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Vhost'}) - exchange: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Exchange'}) - routing_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Routing Key'}) - message_to_publish: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message to Publish'}) - message_encoding: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Encoding'}) - properties: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Properties'}) - queue: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue'}) - - @attrs.define class JobJenkins(Job): @@ -1235,23 +1255,29 @@ class JobJenkins(Job): @attrs.define -class JobVeeamBackup(Job): +class JobRabbitMQ(Job): - _type: str = attrs.field(init=False, default='Job:Veeam Backup', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Veeam Backup'}) + _type: str = attrs.field(init=False, default='Job:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:RabbitMQ'}) 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'}) - backup_u_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Backup UID'}) - retry: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retry'}) - 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'}) + vhost: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Vhost'}) + exchange: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Exchange'}) + routing_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Routing Key'}) + message_to_publish: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message to Publish'}) + message_encoding: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Encoding'}) + properties: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Properties'}) + queue: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue'}) @attrs.define @@ -1294,6 +1320,26 @@ class JobAwsRedshift(Job): '_aapi_repr_': 'Tolerance'}) +@attrs.define +class JobVeeamBackup(Job): + + _type: str = attrs.field(init=False, default='Job:Veeam Backup', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Veeam Backup'}) + 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'}) + backup_u_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Backup UID'}) + retry: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Retry'}) + 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 JobMicrosoftPowerBI(Job): @@ -1478,6 +1524,30 @@ 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): @@ -1520,30 +1590,6 @@ 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): @@ -1825,17 +1871,17 @@ class JobTalendOAuth(Job): @attrs.define -class JobAwsQuickSight(Job): +class JobAzureHDInsight(Job): - _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) + _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Dataset ID'}) - refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Refresh Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bring job logs to 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={ @@ -1843,17 +1889,17 @@ class JobAwsQuickSight(Job): @attrs.define -class JobAzureHDInsight(Job): +class JobAwsQuickSight(Job): - _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) + _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring job logs to output'}) + aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Dataset ID'}) + refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Refresh Type'}) 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={ @@ -1885,10 +1931,10 @@ class JobCircleCI(Job): @attrs.define -class JobAzureWebJobs(Job): +class JobAzureAppServicesWebJobs(Job): - _type: str = attrs.field(init=False, default='Job:Azure WebJobs', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure WebJobs'}) + _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'}) @@ -1900,6 +1946,8 @@ class JobAzureWebJobs(Job): '_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={ @@ -2079,29 +2127,100 @@ class JobAwsLambda(Job): parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log to Output'}) + '_aapi_repr_': 'Append Log to Output'}) + + +@attrs.define +class JobAlteryxTrifacta(Job): + + _type: str = attrs.field(init=False, default='Job:Alteryx Trifacta', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alteryx Trifacta'}) + 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={ + '_aapi_repr_': 'Flow Name'}) + rerun_with_new_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun With New Idempotency Token'}) + idempotent_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Idempotent Token'}) + retrack_job_status: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Retrack Job Status'}) + run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run-ID'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + +@attrs.define +class JobIBMDataStageWindows(Job): + + _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project'}) + datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datastage Job'}) + job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Invocation ID (Optional)'}) + parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameter File'}) + stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Stop Stages After Number Of Rows'}) + abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Abort Job After Number Of Warnings'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log To Output'}) + run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run In Restart Mode'}) + reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reset Job Before Run'}) + empty1: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty1'}) @attrs.define -class JobAlteryxTrifacta(Job): +class JobAwsSQS(Job): - _type: str = attrs.field(init=False, default='Job:Alteryx Trifacta', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alteryx Trifacta'}) + _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'}) - flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) - rerun_with_new_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun With New Idempotency Token'}) - idempotent_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotent Token'}) - retrack_job_status: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retrack Job Status'}) - run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run-ID'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) + 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 @@ -2192,77 +2311,6 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) - - -@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 JobGCPDataprep(Job): @@ -2395,6 +2443,23 @@ class JobDBT(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 JobFivetran(Job): @@ -2419,23 +2484,6 @@ 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): @@ -2710,6 +2758,28 @@ class JobAzureResourceManager(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobAwsStepFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + execution_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execution Name'}) + state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'State Machine ARN'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Execution 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 JobInformaticaCS(Job): @@ -2744,28 +2814,6 @@ class JobInformaticaCS(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsStepFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - execution_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Execution Name'}) - state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'State Machine ARN'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Execution 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 JobTerraform(Job): @@ -2792,7 +2840,6 @@ class JobTerraform(Job): '_aapi_repr_': 'Failure Tolerance'}) - @attrs.define class JobGCPFunctions(Job): @@ -2883,32 +2930,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): @@ -2935,6 +2956,32 @@ class JobOCIDataIntegration(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 JobGCPCloudRun(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index c5975af..a146de6 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.5.2' +__version__ = '2.5.3' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 7c86f93..05dcbd9 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 = ['GDF032022', 'MBI042022', 'BAK092023', 'ODF0420241', 'ADY122023', 'MFL022023', 'GBQ102022', 'NBU032025', 'AWX122024', 'TDM052022', 'GDM082023', 'GWF092023', 'ACF082023', 'VBR062025', 'AAR072022', 'AMM082023', 'UIP072021', 'KBN062023', 'ZBA042022', 'ADB112022', 'ASB012025', 'ADP122022', 'ZFN032022', 'BEC032025', 'AEM072022', 'GCR042024', 'DTG022025', 'ICS032022', 'GDQ112023', 'ACS042023', 'GDU102023', 'AAP092024', 'NFI042024', 'GBA032023', 'VNB032025', 'SFI122022', 'CCI012025', 'ABY122023', 'DBT042023', 'SOP072023', 'ZVM062022', 'DSL122024', 'AAT052023', 'ADF062021', 'QLC092022', 'ADS102024', 'GCC052024', 'DBX032022', 'ADM062025', 'GFU012023', 'RMQ082024', 'ADO112023', 'OVM012024', 'ZWB072025', 'DSW122024', 'GDP042022', 'ABA092022', 'ANS032024', 'AHD062022', 'TAB072023', 'ZML022023', 'ZSY062022', 'ODS052024', 'ZRM082023', 'GVM062022', 'JEN022024', 'AST072024', 'PBI082024', 'ATR122022', 'ARS112024', 'ABK042023', 'MFW022023', 'TDO042024', 'PDY092024', 'VMW102024', 'ZDX112021', 'GDR052023', 'DTG052025', 'AMW112024', 'SBT032025', 'COM032023', 'GLU062021', 'ASQ032024', 'CMR022024', 'RST062023', 'TER102023', 'ALM012024', 'BOO032022', 'AAF112024', 'FVT032025', 'AEC082022', 'SNF092022', 'ZLA112022', 'AQS012023', 'ODI032024', 'ASM0220223', 'ASF012023', 'APP022025'] +IF_PLUGINS = ['AAR072022', 'KBN062023', 'GCR042024', 'ABY122023', 'ABA092022', 'GCC052024', 'PDY092024', 'CMR022024', 'DBX032022', 'GBQ102022', 'RBK072025', 'AHD062022', 'SOP072023', 'GDM082023', 'ZFN032022', 'DTG052025', 'ATR122022', 'CCI012025', 'GDF032022', 'ADO112023', 'DBT042023', 'RST062023', 'ODI032024', 'TER102023', 'GDP042022', 'ZRM082023', 'AAT052023', 'PBI082024', 'MFL022023', 'GWF092023', 'AEM072022', 'ODF0420241', 'ADF062021', 'ASB012025', 'ODS052024', 'VNB032025', 'ASQ032024', 'ZDX112021', 'ASM0220223', 'GFU012023', 'QLC092022', 'ADB112022', 'TAB072023', 'DSW122024', 'GDQ112023', 'COM032023', 'AQS012023', 'AAP092024', 'SNF092022', 'MFW022023', 'NBU032025', 'AWX122024', 'BAK092023', 'NFI042024', 'AAF112024', 'ZWB072025', 'VBR062025', 'GBA032023', 'RMQ082024', 'DTG022025', 'ZSY062022', 'ANS032024', 'GLU062021', 'UIP072021', 'ARS112024', 'FVT032025', 'GDU102023', 'ADS102024', 'TDO042024', 'MBI042022', 'JEN022024', 'APP022025', 'ASF012023', 'SFI122022', 'BOO032022', 'GDR052023', 'ACF082023', 'ICS032022', 'TDM052022', 'ZLA112022', 'VMW102024', 'DSL122024', 'SBT032025', 'ADM062025', 'ZML022023', 'GVM062022', 'ZVM062022', 'ABK042023', 'ACS042023', 'ADY122023', 'ZBA042022', 'ADP122022', 'OVM012024', 'AMW112024', 'AST072024', 'ALM012024', 'BEC032025', 'AEC082022', 'AMM082023'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index e9dd77b..164f3e5 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.2' + assert ctm_python_client.__version__ == '2.5.3'