From 75ddecd710588a9047247420f2728635ed85d53a Mon Sep 17 00:00:00 2001 From: RefaelBeker7 Date: Sun, 26 May 2024 14:51:33 +0300 Subject: [PATCH] Control-M Integrations Factory up to May 2024 --- setup.py | 2 +- .../connection_profiles.py | 384 +++++++++----- src/aapi/integration_factory/jobs.py | 498 ++++++++++++------ src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/ext/autogen.py | 2 +- tests/test_sanity.py | 2 +- 6 files changed, 595 insertions(+), 295 deletions(-) diff --git a/setup.py b/setup.py index db96a53..83e2b55 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.2.5", + version="2.2.6", 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 bbe9a1a..2c74850 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 ConnectionProfileWebServicesREST(ConnectionProfile): @@ -203,6 +203,28 @@ class TokenType(enum.Enum): kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationGoogle'}) +@attrs.define +class ConnectionProfileControlMReports(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:ControlM Reports', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:ControlM Reports'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + control_m_hostname: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Control-M Hostname'}) + control_m_port: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Control-M Port'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Token'}) + 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 ConnectionProfileAwsEC2(ConnectionProfile): @@ -223,6 +245,24 @@ class ConnectionProfileAwsEC2(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileTalendOAuth(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Talend OAuth', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Talend OAuth'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + talend_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Talend API URL'}) + 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'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsBackup(ConnectionProfile): @@ -379,32 +419,10 @@ class ConnectionProfileAwsSNS(ConnectionProfile): '_aapi_repr_': 'AWS SNS URL'}) aws_region: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'AWS Region'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'AWS Access Key'}) aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'AWS Secret'}) - aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_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'}) @@ -431,6 +449,24 @@ class ConnectionProfileAwsLambda(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 ConnectionProfileAlteryxTrifacta(ConnectionProfile): @@ -447,28 +483,6 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsSQS(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS SQS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS SQS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_sqs_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS SQS URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileSnowflakeIdP(ConnectionProfile): @@ -489,6 +503,24 @@ class ConnectionProfileSnowflakeIdP(ConnectionProfile): '_aapi_repr_': 'Scope'}) +@attrs.define +class ConnectionProfileAwsSQS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS SQS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS SQS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_sqs_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS SQS URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + 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'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPDataprep(ConnectionProfile): @@ -571,36 +603,6 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureFunctions(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - 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'}) - function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App Web Site'}) - custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Custom App Key'}) - - @attrs.define class ConnectionProfileDatabricks(ConnectionProfile): @@ -645,6 +647,36 @@ class ConnectionProfileAzureBatchAccounts(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Subscription ID'}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Specify Managed Identity Client ID'}) + managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Managed Identity Client ID'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + 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'}) + function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App Web Site'}) + custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Custom App Key'}) + + @attrs.define class ConnectionProfileAwsEMR(ConnectionProfile): @@ -731,6 +763,38 @@ class ConnectionProfileAzureVM(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 ConnectionProfileDBT(ConnectionProfile): + + _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}) + 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'}) + + @attrs.define class ConnectionProfileAwsAthena(ConnectionProfile): @@ -754,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'}) @@ -1005,6 +1071,32 @@ 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): @@ -1033,6 +1125,24 @@ class ConnectionProfileAzureDataFactory(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 ConnectionProfileAwsStepFunctions(ConnectionProfile): @@ -1076,19 +1186,29 @@ class WebServiceAuthenticationBasic(AAPIObject): @attrs.define -class ConnectionProfileInformaticaCS(ConnectionProfile): +class ConnectionProfileOCIDataScience(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Science', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Science'}) 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'}) + oci_instances_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Instances 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'}) + profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Profile'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1357,28 +1477,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): @@ -1407,6 +1505,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 ConnectionProfileMicroFocusWindows(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 0eb6ee3..d205847 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,9 +174,41 @@ 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 JobWebServicesREST(Job): + @attrs.define + class WsRestBody(AAPIObject): + + request_definition: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RequestDefinition'}) + body_request: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'BodyRequest'}) + file_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'FileName'}) + _type: str = attrs.field(init=False, default='Job:Web Services REST', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Web Services REST'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) @@ -210,6 +220,8 @@ class JobWebServicesREST(Job): '_aapi_repr_': 'Method'}) url_request_path: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'URL Request Path'}) + ws_rest_body: WsRestBody = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'WsRestBody'}) url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'URL Parameters'}) http_headers: str = attrs.field(kw_only=True, default=None, metadata={ @@ -224,6 +236,32 @@ class JobWebServicesREST(Job): '_aapi_repr_': 'Append Response'}) +@attrs.define +class JobControlMReports(Job): + + _type: str = attrs.field(init=False, default='Job:ControlM Reports', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:ControlM Reports'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + control_m_report_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Control-M Report Name'}) + set_download_file_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Set Download File Name'}) + report_file_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Report File Format'}) + agent_attachments_folder: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Agent Attachments Folder'}) + download_destination_folder: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Download Destination Folder'}) + replace_existing_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Replace Existing File'}) + 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): @@ -262,6 +300,46 @@ class JobAwsEC2(Job): '_aapi_repr_': 'Get Instances logs'}) +@attrs.define +class JobTalendOAuth(Job): + + _type: str = attrs.field(init=False, default='Job:Talend OAuth', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Talend OAuth'}) + 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'}) + task_executable: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Executable'}) + environment_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Environment ID'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Name'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + log_level: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Log Level'}) + task_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Timeout'}) + append_task_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Task Logs to Output'}) + plan_executable: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Plan Executable'}) + append_failed_plan_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Failed Plan Logs to Output'}) + rerun_only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Only Failed Tasks'}) + execution_plan_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execution Plan ID'}) + step_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Step ID'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsBackup(Job): @@ -442,6 +520,8 @@ class JobKubernetes(Job): '_aapi_repr_': 'Job Spec Parameters'}) get_pod_logs: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Get Pod Logs'}) + os_exit_code: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OS Exit Code'}) job_cleanup: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Job Cleanup'}) job_status_polling_interval: str = attrs.field(kw_only=True, default=None, metadata={ @@ -510,6 +590,24 @@ class JobAwsSNS(Job): push_attribute5_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Value'}) +@attrs.define +class JobAwsLambda(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Lambda', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Lambda'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + function_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Version'}) + 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'}) + + @attrs.define class JobUIPath(Job): @@ -534,24 +632,6 @@ class JobUIPath(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobAwsLambda(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Lambda', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Lambda'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - function_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Version'}) - 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'}) - - @attrs.define class JobAlteryxTrifacta(Job): @@ -574,43 +654,6 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobAwsSQS(Job): - - _type: str = attrs.field(init=False, default='Job:AWS SQS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS SQS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action Type'}) - queue_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - queue_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue URL'}) - message_body: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Body'}) - delay_seconds: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delay Seconds'}) - message_deduplication_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Deduplication ID'}) - message_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Group ID'}) - message_attributes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Attributes'}) - attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) - attribute1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) - attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) - attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) - attribute2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) - attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) - attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) - attribute3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) - attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) - - @attrs.define class JobSnowflakeIdP(Job): @@ -697,6 +740,43 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Failure Tolerance'}) +@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): @@ -789,28 +869,6 @@ class JobAwsCloudFormation(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'}) - 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'}) - - @attrs.define class JobDatabricks(Job): @@ -869,6 +927,28 @@ 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'}) + 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'}) + + @attrs.define class JobAwsEMR(Job): @@ -967,6 +1047,48 @@ class JobAzureVM(Job): '_aapi_repr_': 'Get Logs'}) +@attrs.define +class JobGCPComposer(Job): + + _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'}) + 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'}) + 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 JobDBT(Job): + + _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'}) + 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={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsAthena(Job): @@ -1016,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={ @@ -1201,6 +1325,10 @@ class JobGCPDataproc(Job): '_aapi_repr_': 'Account Region'}) dataproc_task_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Dataproc task type'}) + batch_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch ID'}) + request_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Request ID'}) workflow_template: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Workflow Template'}) parameters_json_format: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1343,6 +1471,24 @@ 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): @@ -1365,6 +1511,40 @@ class JobAzureDataFactory(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 JobAwsStepFunctions(Job): @@ -1390,6 +1570,16 @@ class JobAwsStepFunctions(Job): @attrs.define class JobWebServicesSOAP(Job): + @attrs.define + class SoapRequest(AAPIObject): + + request_definition: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RequestDefinition'}) + file_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'FileName'}) + soap_request_field: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SoapRequestField'}) + _type: str = attrs.field(init=False, default='Job:Web Services SOAP', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Web Services SOAP'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) @@ -1399,6 +1589,8 @@ class JobWebServicesSOAP(Job): '_aapi_repr_': 'Endpoint URL'}) soap_action: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'SOAP Action'}) + soap_request: SoapRequest = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SoapRequest'}) http_headers: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'HTTP Headers'}) output_handling: typing.List[str] = attrs.field( @@ -1412,33 +1604,21 @@ class JobWebServicesSOAP(Job): @attrs.define -class JobInformaticaCS(Job): +class JobOCIDataScience(Job): - _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) + _type: str = attrs.field(init=False, default='Job:OCI Data Science', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Science'}) 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'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + model_deployment_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Model Deployment ID'}) + notebook_session_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Notebook Session ID'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1829,32 +2009,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): @@ -1881,6 +2035,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 JobMicroFocusWindows(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index c570503..ff9a47b 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.2.5' +__version__ = '2.2.6' __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 4e34515..eec2974 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 = ['TDM052022', 'ZFN032022', 'ADO112023', 'AAT052023', 'DBX032022', 'ALM012024', 'TER102023', 'GDM082023', 'ACS042023', 'GDR052023', 'SOP072023', 'TAB072023', 'ZLA112022', 'ANS032024', 'ADF062021', 'ABY122023', 'ODI032024', 'AHD062022', 'GWF092023', 'ICS032022', 'ADY122023', 'ZML022023', 'ADP122022', 'ZRM082023', 'BAK092023', 'SNF092022', 'ASM0220223', 'ZDX112021', 'UIP072021', 'OVM012024', 'DBT042023', 'ASF012023', 'MFW022023', 'COM032023', 'GDU102023', 'AEC082022', 'BOO032022', 'MFL022023', 'ABK042023', 'ABA092022', 'SFI122022', 'KBN062023', 'GDP042022', 'AEM072022', 'GVM062022', 'GDF032022', 'ZSY062022', 'QLC092022', 'MBI042022', 'ATR122022', 'GLU062021', 'AAR072022', 'AMM082023', 'ZBA042022', 'ACF082023', 'GDQ112023', 'GFU012023', 'ZVM062022', 'AQS012023', 'RST062023', 'ASQ032024', 'GBQ102022', 'JEN022024', 'GBA032023', 'ADB112022'] +IF_PLUGINS = ['ZRM082023', 'GDM082023', 'TAB072023', 'ADF062021', 'ADY122023', 'OVM012024', 'GDU102023', 'TDO042024', 'RST062023', 'GDR052023', 'ZDX112021', 'KBN062023', 'GFU012023', 'TDM052022', 'JEN022024', 'MFL022023', 'MFW022023', 'ABK042023', 'MBI042022', 'AMM082023', 'ZVM062022', 'ASM0220223', 'ADB112022', 'AHD062022', 'GDQ112023', 'ATR122022', 'SOP072023', 'COM032023', 'AAR072022', 'ACS042023', 'ABY122023', 'BAK092023', 'ABA092022', 'ZBA042022', 'TER102023', 'AAT052023', 'AEC082022', 'ADP122022', 'GWF092023', 'ANS032024', 'UIP072021', 'GVM062022', 'AEM072022', 'NFI042024', 'GBA032023', 'ODS052024', 'ASQ032024', 'ASF012023', 'QLC092022', 'BOO032022', 'ADO112023', 'SNF092022', 'DBX032022', 'ZSY062022', 'ALM012024', 'DBT042023', 'ODF0420241', 'GBQ102022', 'ODI032024', 'ICS032022', 'GDP042022', 'GCC052024', 'CMR022024', 'ZML022023', 'SFI122022', 'ZLA112022', 'GDF032022', 'ACF082023', 'AQS012023', 'ZFN032022', 'GLU062021'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 5e37596..86b24e8 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.2.5' + assert ctm_python_client.__version__ == '2.2.6'