From 15ba5f32c675711473d7c3e0a4e2697418fbc65b Mon Sep 17 00:00:00 2001 From: RefaelBeker7 Date: Wed, 4 Sep 2024 10:05:58 +0300 Subject: [PATCH 1/3] fix the value of RunAsDummy in the job SLA --- src/aapi/job.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/aapi/job.py b/src/aapi/job.py index 9cef41b..782f731 100644 --- a/src/aapi/job.py +++ b/src/aapi/job.py @@ -2152,7 +2152,7 @@ class CompleteIn(AAPIObject): _type: str = attrs.field(init=False, default='Job:SLAManagement', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'Job:SLAManagement'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - run_as_dummy: str = attrs.field(kw_only=True, default=None, metadata={ + run_as_dummy: bool = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'RunAsDummy'}) service_name: str = attrs.field(metadata={'_aapi_repr_': 'ServiceName'}) service_priority: str = attrs.field(kw_only=True, default=None, metadata={ From 70210150789a2da46d0b3a42a240b6bb6f611757 Mon Sep 17 00:00:00 2001 From: RefaelBeker7 Date: Wed, 11 Sep 2024 09:08:47 +0300 Subject: [PATCH 2/3] fix workflow.deploy() not raise an error --- src/ctm_python_client/core/comm.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/ctm_python_client/core/comm.py b/src/ctm_python_client/core/comm.py index 24440e5..8757e6b 100644 --- a/src/ctm_python_client/core/comm.py +++ b/src/ctm_python_client/core/comm.py @@ -36,7 +36,7 @@ def wrap(*args, **kwargs): except Exception as e: errors = [err.get('message', '') + ' ' + err.get('item', '') for err in json.loads(e.body)['errors']] - return AAPIClientResponse(False, None, errors) + raise RuntimeError(f"AAPI request failed: {', '.join(errors)}") return wrap From 5e618f67652b5561770fe3ae0da6bc6494dcb84c Mon Sep 17 00:00:00 2001 From: RefaelBeker7 Date: Wed, 18 Sep 2024 11:04:00 +0300 Subject: [PATCH 3/3] Control-M Integrations Factory up to September 2024 --- setup.py | 2 +- .../connection_profiles.py | 386 +++++++------- src/aapi/integration_factory/jobs.py | 470 +++++++++--------- src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/ext/autogen.py | 2 +- tests/test_sanity.py | 2 +- 6 files changed, 432 insertions(+), 432 deletions(-) diff --git a/setup.py b/setup.py index 72715d2..341cf96 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.3.4", + version="2.3.5", 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 6739032..d5dd014 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -68,22 +68,6 @@ class ConnectionProfileAwsMainframeModernization(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): @@ -102,6 +86,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 ConnectionProfileControlMReports(ConnectionProfile): @@ -521,6 +521,20 @@ class ConnectionProfileSnowflakeIdP(ConnectionProfile): '_aapi_repr_': 'Scope'}) +@attrs.define +class ConnectionProfileGCPDataprep(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataprep', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataprep'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + gcp_dataprep_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Dataprep URL'}) + user_access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Access Token'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsGlue(ConnectionProfile): @@ -543,20 +557,6 @@ class ConnectionProfileAwsGlue(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileGCPDataprep(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataprep', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataprep'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - gcp_dataprep_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP Dataprep URL'}) - user_access_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Access Token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsGlueDataBrew(ConnectionProfile): @@ -633,20 +633,6 @@ class ConnectionProfileAzureFunctions(ConnectionProfile): '_aapi_repr_': 'Custom App Key'}) -@attrs.define -class ConnectionProfileDatabricks(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - databricks_workspace_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks workspace url'}) - databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks personal access token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureBatchAccounts(ConnectionProfile): @@ -677,6 +663,20 @@ class ConnectionProfileAzureBatchAccounts(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileDatabricks(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + databricks_workspace_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks workspace url'}) + databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks personal access token'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsEMR(ConnectionProfile): @@ -720,17 +720,29 @@ class ConnectionProfileTableau(ConnectionProfile): @attrs.define -class ConnectionProfileGCPDataplex(ConnectionProfile): +class ConnectionProfileAzureVM(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure VM', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure VM'}) 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'}) + 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'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection timeout'}) @@ -752,47 +764,33 @@ class ConnectionProfileGCPComposer(ConnectionProfile): @attrs.define -class ConnectionProfileAzureVM(ConnectionProfile): +class ConnectionProfileGCPDataplex(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure VM'}) + _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}) - 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'}) + 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 ConnectionProfileApacheNiFi(ConnectionProfile): +class ConnectionProfileDBT(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'NiFi 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'}) + dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT URL'}) + dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Token'}) + account_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account ID'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -820,17 +818,19 @@ class ConnectionProfileAwsAthena(ConnectionProfile): @attrs.define -class ConnectionProfileDBT(ConnectionProfile): +class ConnectionProfileApacheNiFi(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT URL'}) - dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Token'}) - account_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account ID'}) + ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'NiFi 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'}) @@ -1071,32 +1071,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): @@ -1125,6 +1099,32 @@ class ConnectionProfileAzureDataFactory(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 ConnectionProfileAwsStepFunctions(ConnectionProfile): @@ -1147,6 +1147,24 @@ class ConnectionProfileAwsStepFunctions(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'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileWebServicesSOAP(ConnectionProfile): @@ -1167,24 +1185,6 @@ class WebServiceAuthenticationBasic(AAPIObject): kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationBasic'}) -@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'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileOCIDataScience(ConnectionProfile): @@ -1347,6 +1347,24 @@ class ConnectionProfileAzureLogicApps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileQlikCloud(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Qlik API URL'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + api_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileJenkins(ConnectionProfile): @@ -1364,21 +1382,23 @@ class ConnectionProfileJenkins(ConnectionProfile): @attrs.define -class ConnectionProfileQlikCloud(ConnectionProfile): +class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) + _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}) - qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Qlik API URL'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - api_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + 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 @@ -1409,26 +1429,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): @@ -1477,6 +1477,28 @@ 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): @@ -1505,28 +1527,6 @@ 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 ConnectionProfileMicroFocusWindows(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index a11c170..9adcce1 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -144,28 +144,6 @@ class JobAwsMainframeModernization(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 JobAzureDevOps(Job): @@ -196,6 +174,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 JobControlMReports(Job): @@ -777,26 +777,6 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsGlue(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Glue', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Glue'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Glue Job Name'}) - glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Glue Job Arguments'}) - arguments: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Arguments'}) - 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 JobGCPDataprep(Job): @@ -819,6 +799,26 @@ class JobGCPDataprep(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAwsGlue(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Glue', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Glue'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Job Name'}) + glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Job Arguments'}) + arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Arguments'}) + 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 JobAwsGlueDataBrew(Job): @@ -891,24 +891,6 @@ class JobAzureFunctions(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobDatabricks(Job): - - _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks Job ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotency Token'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobAzureBatchAccounts(Job): @@ -949,6 +931,24 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) +@attrs.define +class JobDatabricks(Job): + + _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks Job ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Idempotency Token'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobAwsEMR(Job): @@ -998,29 +998,27 @@ class JobTableau(Job): @attrs.define -class JobGCPDataplex(Job): +class JobAzureVM(Job): - _type: str = attrs.field(init=False, default='Job:GCP Dataplex', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataplex'}) + _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'}) - 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'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - scan_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Scan Name'}) - lake_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Lake Name'}) - task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task 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'}) + 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'}) + 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'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) @attrs.define @@ -1044,47 +1042,47 @@ class JobGCPComposer(Job): @attrs.define -class JobAzureVM(Job): +class JobGCPDataplex(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 Dataplex', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataplex'}) 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'}) - 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'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) + 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'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + scan_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scan Name'}) + lake_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Lake Name'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task 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 JobApacheNiFi(Job): +class JobDBT(Job): - _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) + _type: str = attrs.field(init=False, default='Job:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor Group ID'}) - processor_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Disconnected Node Ack'}) - parameters_: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters '}) + dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Job Id'}) + run_comment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Comment'}) + override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Override Job Commands'}) + define_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Define Commands'}) 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={ @@ -1140,21 +1138,23 @@ class JobAwsAthena(Job): @attrs.define -class JobDBT(Job): +class JobApacheNiFi(Job): - _type: str = attrs.field(init=False, default='Job:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) + _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Job Id'}) - run_comment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run Comment'}) - override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Override Job Commands'}) - define_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Define Commands'}) + processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor Group ID'}) + processor_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Disconnected Node Ack'}) + parameters_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters '}) 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={ @@ -1471,24 +1471,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): @@ -1511,6 +1493,24 @@ class JobAzureDataFactory(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 JobAwsStepFunctions(Job): @@ -1533,6 +1533,40 @@ class JobAwsStepFunctions(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobInformaticaCS(Job): + + _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + task_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Type'}) + use_federation_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Use Federation ID'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Name'}) + folder_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Path'}) + taskflow_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Taskflow Job Name'}) + task_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'TaskFlow URL'}) + rerun_suspended_taskflow: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Suspended Taskflow'}) + rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Run ID'}) + input_fields: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Fields'}) + call_back_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Call Back URL'}) + 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): @@ -1569,40 +1603,6 @@ class SoapRequest(AAPIObject): '_aapi_repr_': 'Append Response'}) -@attrs.define -class JobInformaticaCS(Job): - - _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - task_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Type'}) - use_federation_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Use Federation ID'}) - task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Name'}) - folder_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Path'}) - taskflow_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Taskflow Job Name'}) - task_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'TaskFlow URL'}) - rerun_suspended_taskflow: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Suspended Taskflow'}) - rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Run ID'}) - input_fields: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Input Fields'}) - call_back_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Call Back URL'}) - 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 JobOCIDataScience(Job): @@ -1797,6 +1797,26 @@ class JobAzureLogicApps(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobQlikCloud(Job): + + _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + reload_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reload Type'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Print Log to Output'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + + @attrs.define class JobJenkins(Job): @@ -1822,23 +1842,29 @@ class JobJenkins(Job): @attrs.define -class JobQlikCloud(Job): +class JobMicrosoftPowerBI(Job): - _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) + _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'}) - reload_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reload Type'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Print Log to Output'}) + 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'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) @attrs.define @@ -1879,32 +1905,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): @@ -2009,32 +2009,6 @@ class JobOCIVM(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobOCIDataIntegration(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - actions: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Actions'}) - workspace_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace OCID'}) - application_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application Key'}) - task_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Key'}) - task_run_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Run Name'}) - task_run_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Run Input Parameters'}) - 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 JobAwsDataPipeline(Job): @@ -2061,6 +2035,32 @@ class JobAwsDataPipeline(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobOCIDataIntegration(Job): + + _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + actions: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Actions'}) + workspace_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace OCID'}) + application_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application Key'}) + task_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Key'}) + task_run_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Run Name'}) + task_run_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Run Input Parameters'}) + 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 JobMicroFocusWindows(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 7b1c3e0..3caa240 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.3.4' +__version__ = '2.3.5' __author__ = 'BMC Software' \ No newline at end of file diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index e2de608..9067bdd 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 = ['ODF0420241', 'ABY122023', 'ASQ032024', 'OVM012024', 'ADB112022', 'GLU062021', 'ZSY062022', 'ZML022023', 'ATR122022', 'ADP122022', 'ASF012023', 'AAT052023', 'JEN022024', 'GDR052023', 'TER102023', 'TDM052022', 'SFI122022', 'ODS052024', 'ALM012024', 'GDQ112023', 'GDF032022', 'GCC052024', 'ICS032022', 'ABA092022', 'COM032023', 'ODI032024', 'DBX032022', 'DBT042023', 'ZDX112021', 'ACF082023', 'GDM082023', 'ZRM082023', 'AQS012023', 'GDP042022', 'ZLA112022', 'UIP072021', 'ADO112023', 'AAR072022', 'AEM072022', 'AHD062022', 'ANS032024', 'ASM0220223', 'SOP072023', 'ABK042023', 'MFW022023', 'RST062023', 'ZBA042022', 'SNF092022', 'AMM082023', 'AEC082022', 'GBA032023', 'MBI042022', 'GDU102023', 'TDO042024', 'GWF092023', 'MFL022023', 'KBN062023', 'ADY122023', 'NFI042024', 'CMR022024', 'TAB072023', 'GBQ102022', 'ACS042023', 'BOO032022', 'QLC092022', 'ZVM062022', 'BAK092023', 'ZFN032022', 'ADF062021', 'GVM062022', 'GFU012023'] +IF_PLUGINS = ['ODF0420241', 'ADO112023', 'GWF092023', 'AMM082023', 'ZML022023', 'ABA092022', 'ASM0220223', 'GBA032023', 'COM032023', 'ZDX112021', 'NFI042024', 'TAB072023', 'SNF092022', 'GDF032022', 'DBT042023', 'OVM012024', 'AHD062022', 'MFL022023', 'GBQ102022', 'ZFN032022', 'ZBA042022', 'UIP072021', 'JEN022024', 'MFW022023', 'ZVM062022', 'ALM012024', 'TDO042024', 'BAK092023', 'ODI032024', 'ADP122022', 'TDM052022', 'AEC082022', 'AAT052023', 'ODS052024', 'MBI042022', 'GDP042022', 'ANS032024', 'CMR022024', 'ASF012023', 'ADF062021', 'TER102023', 'AQS012023', 'GDQ112023', 'GLU062021', 'ZSY062022', 'BOO032022', 'ACS042023', 'ACF082023', 'GFU012023', 'SFI122022', 'GDU102023', 'ADY122023', 'ZLA112022', 'ATR122022', 'GDR052023', 'QLC092022', 'GCC052024', 'AAR072022', 'ABK042023', 'DBX032022', 'KBN062023', 'ICS032022', 'GVM062022', 'ZRM082023', 'RST062023', 'ABY122023', 'AEM072022', 'SOP072023', 'ADB112022', 'GDM082023', 'ASQ032024'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 0552659..f10a798 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.3.4' + assert ctm_python_client.__version__ == '2.3.5'