From 2a64c604763fe0928db3ea495046572fed04025d Mon Sep 17 00:00:00 2001 From: ybauming_bmcgit Date: Sun, 12 Apr 2026 21:43:17 +0300 Subject: [PATCH 1/2] WBL-378889 Control-M Integrations Factory up to April 2026 --- setup.py | 2 +- .../connection_profiles.py | 756 +++++++++++------ src/aapi/integration_factory/jobs.py | 763 +++++++++++------- src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/ext/autogen.py | 2 +- tests/test_sanity.py | 2 +- 6 files changed, 973 insertions(+), 554 deletions(-) diff --git a/setup.py b/setup.py index 508c111..faef1d4 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.6.0", + version="2.6.1", 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 5907ccc..60784a5 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -130,6 +130,30 @@ class ConnectionProfileGCPDeploymentManager(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileSAPIBP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:SAP IBP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:SAP IBP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + host: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Host'}) + service_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service URL'}) + 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'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsEC2(ConnectionProfile): @@ -276,6 +300,24 @@ class ConnectionProfileGCPDataFusion(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileUIPath(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Name'}) + tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Url'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + app_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App Secret'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileDatadog(ConnectionProfile): @@ -298,24 +340,6 @@ class ConnectionProfileDatadog(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileUIPath(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Name'}) - tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Url'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - app_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App Secret'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsGlue(ConnectionProfile): @@ -398,6 +422,72 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerAutomate(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power Automate', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power Automate'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + power_automate_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Power Automate URL'}) + resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource'}) + 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'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + 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'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_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'}) + resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource'}) + custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Custom App Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsAppFlow(ConnectionProfile): @@ -460,40 +550,6 @@ class ConnectionProfileAzureBatchAccounts(ConnectionProfile): '_aapi_repr_': 'Rerun Attempts'}) -@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'}) - resource: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource'}) - custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Custom App Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsEMR(ConnectionProfile): @@ -537,35 +593,35 @@ class ConnectionProfileTableau(ConnectionProfile): @attrs.define -class ConnectionProfileGCPComposer(ConnectionProfile): +class ConnectionProfileGCPDataplex(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) + _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}) - 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'}) + 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'}) + '_aapi_repr_': 'Connection timeout'}) @attrs.define -class ConnectionProfileGCPDataplex(ConnectionProfile): +class ConnectionProfileGCPComposer(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: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'}) - 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'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -679,61 +735,61 @@ class ConnectionProfileGCPDataflow(ConnectionProfile): @attrs.define -class ConnectionProfileAwsBedrock(ConnectionProfile): +class ConnectionProfileAwsMWAA(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Bedrock', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Bedrock'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS MWAA', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS MWAA'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - bedrock_agent_runtime_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bedrock Agent Runtime URL'}) + aws_m_w_a_a_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS MWAA URL'}) aws_region: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) + 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'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) + aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS IAM Role'}) assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Assume Role ARN'}) assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Assume Role Session'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) - http_codes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'HTTP Codes'}) - rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Interval'}) - attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Attempt Reruns'}) @attrs.define -class ConnectionProfileAwsMWAA(ConnectionProfile): +class ConnectionProfileAwsBedrock(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS MWAA', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS MWAA'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Bedrock', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Bedrock'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_m_w_a_a_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS MWAA URL'}) + bedrock_agent_runtime_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bedrock Agent Runtime 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'}) + 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'}) - aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Assume Role ARN'}) assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Assume Role Session'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) @attrs.define @@ -908,6 +964,12 @@ class ConnectionProfileAzureMachineLearning(ConnectionProfile): '_aapi_repr_': 'Application ID'}) client_secret: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Client Secret'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -946,32 +1008,6 @@ class ConnectionProfileAzureDataFactory(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) -@attrs.define -class ConnectionProfileOCIDataFlow(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Data Flow URL'}) - oci_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User OCID'}) - tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenancy OCID'}) - fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fingerprint'}) - private_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Private Key'}) - config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Config File Path'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileWebServicesSOAP(ConnectionProfile): @@ -1020,6 +1056,32 @@ class ConnectionProfileOCIDataScience(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileSAPDatasphere(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:SAP Datasphere', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:SAP Datasphere'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Base URL'}) + token_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Token URL'}) + 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'}) + refresh_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Refresh Token'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileBoomiAtomsphere(ConnectionProfile): @@ -1158,6 +1220,24 @@ class ConnectionProfileLangGraph(ConnectionProfile): '_aapi_repr_': 'Rerun Attempts'}) +@attrs.define +class ConnectionProfileRabbitMQ(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RabbitMQ URL'}) + port: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Port'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileJenkins(ConnectionProfile): @@ -1180,24 +1260,6 @@ class ConnectionProfileJenkins(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileRabbitMQ(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:RabbitMQ', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'RabbitMQ URL'}) - port: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Port'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileMicrosoftFabric(ConnectionProfile): @@ -1222,6 +1284,8 @@ class ConnectionProfileMicrosoftFabric(ConnectionProfile): '_aapi_repr_': 'Client Secret'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + request_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Request Timeout'}) http_codes: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'HTTP Codes'}) rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1230,28 +1294,6 @@ class ConnectionProfileMicrosoftFabric(ConnectionProfile): '_aapi_repr_': 'Rerun Attempts'}) -@attrs.define -class ConnectionProfileAwsRedshift(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Redshift', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Redshift'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Base URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key ID'}) - aws_secret_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret Access Key'}) - 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 ConnectionProfileVeeamBackup(ConnectionProfile): @@ -1278,6 +1320,28 @@ class ConnectionProfileVeeamBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsRedshift(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Redshift', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Redshift'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Base URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key ID'}) + aws_secret_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret Access Key'}) + 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 ConnectionProfileAzureBackup(ConnectionProfile): @@ -1384,32 +1448,6 @@ class ConnectionProfileMicrosoftPowerBISP(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Database Migration Service', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Database Migration Service'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_d_m_s_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS DMS URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role ARN'}) - assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role Session'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileMicroFocusWindows(ConnectionProfile): @@ -1436,6 +1474,32 @@ class ConnectionProfileMicroFocusWindows(ConnectionProfile): '_aapi_repr_': 'RunAs-Pass'}) +@attrs.define +class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Database Migration Service', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Database Migration Service'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_d_m_s_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS DMS URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileIBMDataStageLinux(ConnectionProfile): @@ -1461,21 +1525,98 @@ class ConnectionProfileIBMDataStageLinux(ConnectionProfile): @attrs.define -class ConnectionProfileAlibabaECS(ConnectionProfile): +class ConnectionProfileAlibabaECS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Alibaba ECS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Alibaba ECS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Access Key ID'}) + secret_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Secret Access Key'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + +@attrs.define +class ConnectionProfileApacheKafkaViaConfluent(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Apache Kafka via Confluent', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache Kafka via Confluent'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + kafka_deployment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Kafka Deployment'}) + kafka_cluster_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Kafka Cluster URL'}) + cluster_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster ID'}) + kafka_authentication_endpoint: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Kafka Authentication Endpoint'}) + confluent_authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Confluent Authentication Method'}) + api_key_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key ID'}) + api_key_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key Secret'}) + o_auth_2.0_token_endpoint: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'OAuth 2.0 Token Endpoint'}) + 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'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Token'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + rerun_attempts: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Attempts'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + +@attrs.define +class ConnectionProfileSnowflakeCortexAI(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Alibaba ECS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Alibaba ECS'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake Cortex AI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake Cortex AI'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Access Key ID'}) - secret_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Secret Access Key'}) + snowflake_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Snowflake URL'}) + account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Identifier'}) region: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Region'}) - api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API-VERSION'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) + snowflake_oauth_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Snowflake Oauth Client ID'}) + snowflake_oauth_client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Snowflake Oauth Client Secret'}) + refresh_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Refresh Token'}) + redirect_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Redirect URL'}) + 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'}) + identity_provider_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Provider URL'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Access Token'}) @attrs.define @@ -1639,6 +1780,34 @@ class TokenType(enum.Enum): kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationGoogle'}) +@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'}) + 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'}) + + @attrs.define class ConnectionProfileTalendOAuth(ConnectionProfile): @@ -1657,22 +1826,6 @@ class ConnectionProfileTalendOAuth(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureHDInsight(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Name'}) - cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Username'}) - cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsQuickSight(ConnectionProfile): @@ -1697,6 +1850,22 @@ class ConnectionProfileAwsQuickSight(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureHDInsight(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Name'}) + cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Username'}) + cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAtlassianJira(ConnectionProfile): @@ -1715,6 +1884,20 @@ class ConnectionProfileAtlassianJira(ConnectionProfile): '_aapi_repr_': 'Jira Data Center URL'}) jira_data_center_token: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Jira Data Center Token'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) + jira_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Jira API URL'}) + cloud_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cloud ID'}) + service_account_email: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Email'}) + s_p_api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SP API Token'}) + 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'}) @@ -1767,6 +1950,38 @@ class ConnectionProfileAzureAppServicesWebJobs(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileOracleFusionCloudESS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Oracle Fusion Cloud ESS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Oracle Fusion Cloud ESS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + oracle_fusion_cloud_e_s_s_url: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Oracle Fusion Cloud ESS URL'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) + 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'}) + access_token_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Access Token URL'}) + 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'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + rerun_attempts: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Attempts'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsSageMaker(ConnectionProfile): @@ -2014,6 +2229,28 @@ class ConnectionProfileAwsSQS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileSnowflakeIdP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Identifier'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + idp_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IDP URL'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + + @attrs.define class ConnectionProfileIBMDataStageWindows(ConnectionProfile): @@ -2038,28 +2275,6 @@ class ConnectionProfileIBMDataStageWindows(ConnectionProfile): '_aapi_repr_': 'DSJOB Path'}) -@attrs.define -class ConnectionProfileSnowflakeIdP(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Endpoint URL'}) - account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account Identifier'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - idp_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IDP URL'}) - scope: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Scope'}) - - @attrs.define class ConnectionProfileGCPDataprep(ConnectionProfile): @@ -2172,6 +2387,20 @@ class ConnectionProfileAwsAthena(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileFivetran(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fivetran Base URL'}) + api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Base 64 Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureServiceBus(ConnectionProfile): @@ -2200,20 +2429,6 @@ class ConnectionProfileAzureServiceBus(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileFivetran(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fivetran Base URL'}) - api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Base 64 Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -2326,6 +2541,12 @@ class ConnectionProfileTalendDataManagement(ConnectionProfile): '_aapi_repr_': 'Region'}) connection_timout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionTimout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + rerun_attempts: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Attempts'}) @attrs.define @@ -2410,30 +2631,6 @@ class ConnectionProfileAzureResourceManager(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileInformaticaCS(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Login URL'}) - base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Base URL'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - http_codes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'HTTP Codes'}) - rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Interval'}) - attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Attempt Reruns'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsStepFunctions(ConnectionProfile): @@ -2466,6 +2663,30 @@ class ConnectionProfileAwsStepFunctions(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileInformaticaCS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Login URL'}) + base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Base URL'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileTerraform(ConnectionProfile): @@ -2480,6 +2701,7 @@ class ConnectionProfileTerraform(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) + @attrs.define class ConnectionProfileAtlassianBitbucket(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 93ff8ff..759b973 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -160,6 +160,28 @@ class JobGCPDeploymentManager(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobSAPIBP(Job): + + _type: str = attrs.field(init=False, default='Job:SAP IBP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:SAP IBP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + job_template_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'JobTemplate Type'}) + job_template: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Template'}) + job_user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job User'}) + job_text_suffix: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Text Suffix'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsEC2(Job): @@ -362,6 +384,32 @@ class JobGCPDataFusion(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobUIPath(Job): + + _type: str = attrs.field(init=False, default='Job:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + folder_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Type'}) + folder_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Name'}) + folder_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Id'}) + process_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Process Name'}) + robot_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Robot Name'}) + robot_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Robot Id'}) + optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Input Parameters'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobDatadog(Job): @@ -394,32 +442,6 @@ class JobDatadog(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobUIPath(Job): - - _type: str = attrs.field(init=False, default='Job:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - folder_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Type'}) - folder_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Name'}) - folder_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Id'}) - process_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Process Name'}) - robot_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Name'}) - robot_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Id'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobAwsGlue(Job): @@ -526,6 +548,58 @@ class JobAwsCloudFormation(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobMicrosoftPowerAutomate(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Power Automate', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power Automate'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + environment_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Environment ID'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + fetch_detailed_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fetch Detailed Logs'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + +@attrs.define +class JobAzureFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_app: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App'}) + azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource'}) + azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource Scope'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Input Parameters'}) + function_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Type'}) + verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Intervall'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) + + @attrs.define class JobAwsAppFlow(Job): @@ -592,34 +666,6 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) -@attrs.define -class JobAzureFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_app: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App'}) - azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Resource'}) - azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Resource Scope'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - function_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Type'}) - verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Intervall'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API-VERSION'}) - - @attrs.define class JobAwsEMR(Job): @@ -668,6 +714,32 @@ class JobTableau(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPDataplex(Job): + + _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'}) + 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 JobGCPComposer(Job): @@ -676,6 +748,8 @@ class JobGCPComposer(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) + airflow_rest_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Airflow REST Version'}) action: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Action'}) d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -684,10 +758,16 @@ class JobGCPComposer(Job): '_aapi_repr_': 'DAG Run ID'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) + logical_date: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Logical Date'}) only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Only Failed Tasks'}) include_subdags: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Include Subdags'}) + include_upstream: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Include Upstream'}) + include_downstream: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Include Downstream'}) switch_to_rerun: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Switch to Rerun'}) keep_run_id: str = attrs.field(kw_only=True, default=None, metadata={ @@ -700,32 +780,6 @@ class JobGCPComposer(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobGCPDataplex(Job): - - _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'}) - 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 JobAzureVM(Job): @@ -882,6 +936,32 @@ class JobGCPDataflow(Job): '_aapi_repr_': 'Log Level'}) +@attrs.define +class JobAwsMWAA(Job): + + _type: str = attrs.field(init=False, default='Job:AWS MWAA', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS MWAA'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + m_w_a_a_environment_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MWAA Environment Name'}) + d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Name'}) + d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Run ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + only_failed: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Only Failed'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsBedrock(Job): @@ -912,32 +992,6 @@ class JobAwsBedrock(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsMWAA(Job): - - _type: str = attrs.field(init=False, default='Job:AWS MWAA', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS MWAA'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - m_w_a_a_environment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'MWAA Environment Name'}) - d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Name'}) - d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Run ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - only_failed: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Only Failed'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobVeritasNetBackup(Job): @@ -1166,6 +1220,8 @@ class JobAzureMachineLearning(Job): '_aapi_repr_': 'Action'}) pipeline_endpoint_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Pipeline Endpoint ID'}) + job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job ID'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) compute_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1204,24 +1260,6 @@ class JobAzureDataFactory(Job): '_aapi_repr_': 'Reference Pipeline Run ID'}) -@attrs.define -class JobOCIDataFlow(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Compartment OCID'}) - application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application OCID'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobWebServicesSOAP(Job): @@ -1280,6 +1318,30 @@ class JobOCIDataScience(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobSAPDatasphere(Job): + + _type: str = attrs.field(init=False, default='Job:SAP Datasphere', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:SAP Datasphere'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + space_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Space ID'}) + datasphere_task_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datasphere Task Type'}) + task_chain_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Chain Name'}) + replication_flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Replication Flow Name'}) + correlation_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Correlation 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 JobBoomiAtomsphere(Job): @@ -1318,6 +1380,18 @@ class JobAzureDatabricks(Job): '_aapi_repr_': 'Idempotency Token'}) show_tasks_output: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Show Tasks Output'}) + repair_on_rerun: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Repair on Rerun'}) + reference_job_run_id__: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reference Job Run ID '}) + latest_repair_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Latest Repair ID'}) + rerun_all_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun all Failed Tasks'}) + rerun_dependent_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Dependent Tasks'}) + rerun_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Tasks'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1478,32 +1552,6 @@ class JobLangGraph(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobJenkins(Job): - - _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Parameters'}) - parameters: typing.List[str] = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) - add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Branch Name'}) - branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Branch Name'}) - fetch_console_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fetch Console Logs'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobRabbitMQ(Job): @@ -1530,6 +1578,32 @@ class JobRabbitMQ(Job): '_aapi_repr_': 'Queue'}) +@attrs.define +class JobJenkins(Job): + + _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Parameters'}) + parameters: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) + add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Branch Name'}) + branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Branch Name'}) + fetch_console_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fetch Console Logs'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobMicrosoftFabric(Job): @@ -1552,6 +1626,26 @@ class JobMicrosoftFabric(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobVeeamBackup(Job): + + _type: str = attrs.field(init=False, default='Job:Veeam Backup', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Veeam Backup'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + backup_u_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Backup UID'}) + retry: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Retry'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsRedshift(Job): @@ -1592,26 +1686,6 @@ class JobAwsRedshift(Job): '_aapi_repr_': 'Tolerance'}) -@attrs.define -class JobVeeamBackup(Job): - - _type: str = attrs.field(init=False, default='Job:Veeam Backup', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Veeam Backup'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - backup_u_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Backup UID'}) - retry: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retry'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureBackup(Job): @@ -1796,30 +1870,6 @@ class JobMicrosoftPowerBISP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsDatabaseMigrationService(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Database Migration Service', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Database Migration Service'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - data_migration_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Migration ARN'}) - start_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Start Type'}) - database_migration_task_arn: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Database Migration Task ARN'}) - output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Output Job Logs'}) - failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance '}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobMicroFocusWindows(Job): @@ -1862,6 +1912,30 @@ class JobMicroFocusWindows(Job): kw_only=True, default=None, metadata={'_aapi_repr_': 'Modified JCL Path and Filename'}) +@attrs.define +class JobAwsDatabaseMigrationService(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Database Migration Service', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Database Migration Service'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + data_migration_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Migration ARN'}) + start_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Start Type'}) + database_migration_task_arn: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Database Migration Task ARN'}) + output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output Job Logs'}) + failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance '}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobIBMDataStageLinux(Job): @@ -1918,6 +1992,54 @@ class JobAlibabaECS(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobApacheKafkaViaConfluent(Job): + + _type: str = attrs.field(init=False, default='Job:Apache Kafka via Confluent', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache Kafka via Confluent'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + topic_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Topic Name'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + + +@attrs.define +class JobSnowflakeCortexAI(Job): + + _type: str = attrs.field(init=False, default='Job:Snowflake Cortex AI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Snowflake Cortex AI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + database: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Database'}) + schema: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Schema'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + cortex_ai_agent_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cortex AI Agent Name'}) + input_text: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Text'}) + tool_names: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tool Names'}) + fail_job_on_response_text: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fail job on response text'}) + m_c_p_server_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MCP Server Name'}) + m_c_p_server_request_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MCP Server Request ID'}) + m_c_p_server_tool_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MCP Server Tool Name'}) + m_c_p_server_tool_arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MCP Server Tool Arguments'}) + timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Timeout'}) + + @attrs.define class JobAnsibleAWX(Job): @@ -2102,6 +2224,32 @@ class WsRestBody(AAPIObject): '_aapi_repr_': 'Append Response'}) +@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'}) + run_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Name'}) + 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'}) + additional_run_details: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Additional Run Details'}) + run_details_configuration: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Details Configuration'}) + get_run_information: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Run Information'}) + 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 JobTalendOAuth(Job): @@ -2143,17 +2291,17 @@ class JobTalendOAuth(Job): @attrs.define -class JobAzureHDInsight(Job): +class JobAwsQuickSight(Job): - _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) + _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring job logs to output'}) + aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Dataset ID'}) + refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Refresh Type'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2161,17 +2309,17 @@ class JobAzureHDInsight(Job): @attrs.define -class JobAwsQuickSight(Job): +class JobAzureHDInsight(Job): - _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) + _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Dataset ID'}) - refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Refresh Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bring job logs to output'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2190,6 +2338,8 @@ class JobAtlassianJira(Job): '_aapi_repr_': 'Action'}) issue_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Issue Key'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'UserName'}) issue_parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Issue Parameters'}) transition_id: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2248,6 +2398,34 @@ class JobAzureAppServicesWebJobs(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobOracleFusionCloudESS(Job): + + _type: str = attrs.field(init=False, default='Job:Oracle Fusion Cloud ESS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Oracle Fusion Cloud ESS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + job_definition_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Definition ID'}) + application_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application Name'}) + request_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Request Parameters'}) + optional_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Parameters'}) + product: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Product'}) + description: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Description'}) + callback_subscription: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Callback Subscription'}) + 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 JobAwsSageMaker(Job): @@ -2481,40 +2659,6 @@ class JobAwsSQS(Job): attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) - - @attrs.define class JobSnowflakeIdP(Job): @@ -2603,6 +2747,40 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobIBMDataStageWindows(Job): + + _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project'}) + datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datastage Job'}) + job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Invocation ID (Optional)'}) + parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameter File'}) + stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Stop Stages After Number Of Rows'}) + abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Abort Job After Number Of Warnings'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log To Output'}) + run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run In Restart Mode'}) + reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reset Job Before Run'}) + empty1: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty1'}) + + @attrs.define class JobGCPDataprep(Job): @@ -2665,6 +2843,18 @@ class JobDatabricks(Job): '_aapi_repr_': 'Idempotency Token'}) show_tasks_output: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Show Tasks Output'}) + repair_on_rerun: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Repair on Rerun'}) + reference_job_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reference Job Run ID'}) + latest_repair_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Latest Repair ID'}) + rerun_all_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun all Failed Tasks'}) + rerun_dependent_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Dependent Tasks'}) + rerun_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Tasks'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2741,23 +2931,6 @@ class JobAwsAthena(Job): '_aapi_repr_': 'NoPerm'}) -@attrs.define -class JobAzureServiceBus(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Bus Namespace'}) - queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) - message_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Format'}) - message_body: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Body'}) - - @attrs.define class JobFivetran(Job): @@ -2782,6 +2955,23 @@ class JobFivetran(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureServiceBus(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Bus Namespace'}) + queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) + message_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Format'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) + + @attrs.define class JobAwsBatch(Job): @@ -2884,8 +3074,8 @@ class JobGCPBigQuery(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - project_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project Name'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Id'}) dataset_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Dataset Name'}) action: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2918,12 +3108,18 @@ class JobGCPBigQuery(Job): '_aapi_repr_': 'Show Load Options'}) load_options: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Load Options'}) + print_header: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Print Header'}) + field_delimiter: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Field Delimiter'}) job_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Job Timeout'}) 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'}) + empty: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty'}) @attrs.define @@ -3084,6 +3280,28 @@ class JobAzureResourceManager(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobAwsStepFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + execution_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execution Name'}) + state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'State Machine ARN'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Execution Logs'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobInformaticaCS(Job): @@ -3120,28 +3338,6 @@ class JobInformaticaCS(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsStepFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - execution_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Execution Name'}) - state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'State Machine ARN'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Execution Logs'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobTerraform(Job): @@ -3168,6 +3364,7 @@ class JobTerraform(Job): '_aapi_repr_': 'Failure Tolerance'}) + @attrs.define class JobAtlassianBitbucket(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 72f7140..a62ce0d 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.6.0' +__version__ = '2.6.1' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 7a1f9a6..caff3a5 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 = ['GWF092023', 'MFL022023', 'ARS112024', 'ZRM082023', 'DSW122024', 'ADY122023', 'MPA032026', 'DTG022025', 'ABY122023', 'GVM062022', 'VMW102024', 'LAN012026', 'VNB032025', 'JCP102025', 'AST072024', 'VBR062025', 'NBU032025', 'ABB092025', 'ADF062021', 'DSL122024', 'SNF092022', 'TAB072023', 'ZDX112021', 'ANS032024', 'DTG052025', 'MFB062025', 'ZVM062022', 'OFC032026', 'ICS032022', 'MAT022025', 'TDM052022', 'APK032026', 'GEA072025', 'GCC052024', 'ODI032024', 'ADO112023', 'ASF012023', 'COM032023', 'GIT092025', 'TDO042024', 'AEC082022', 'GBA032023', 'ALM012024', 'FVT032025', 'ZWB072025', 'ODS052024', 'BAK092023', 'PDY092024', 'OVM012024', 'TER102023', 'AAP092024', 'ASQ032024', 'ODF0420241', 'GCR042024', 'ADM062025', 'RMQ082024', 'ASM0220223', 'AQS012023', 'DBT042023', 'ODF062024', 'GBQ102022', 'GDU102023', 'GDM082023', 'MFW022023', 'ACS042023', 'GLU062021', 'AAF112024', 'ABR092025', 'ABK042023', 'AMM082023', 'GDP042022', 'PBI082024', 'SDS122025', 'ADP122022', 'ADB112022', 'ACF082023', 'CRW122025', 'CCI012025', 'GDR052023', 'BEC032025', 'BOO032022', 'ZSY062022', 'ASB012025', 'GDQ112023', 'ZFN032022', 'AMW112024', 'CMR022024', 'QLC092022', 'UIP072021', 'SFI122022', 'ZLA112022', 'ABA092022', 'ATR122022', 'GFU012023', 'AEM072022', 'GDF032022', 'ADS102024', 'NFI042024', 'AAT052023', 'RBK072025', 'ZBA042022', 'SNC022026', 'SBT032025', 'ZML022023', 'KBN062023', 'APP022025', 'SOP072023', 'AAR072022', 'AWX122024', 'DBX032022', 'GVA092025', 'MBI042022', 'AHD062022', 'JEN022024', 'RST062023'] +IF_PLUGINS = ['ASB012025', 'GDR052023', 'AMM082023', 'ABY122023', 'JEN022024', 'ADS102024', 'MFW022023', 'JCP102025', 'GCR042024', 'ASQ032024', 'GDQ112023', 'FVT032025', 'ZML022023', 'MFL022023', 'GEA072025', 'BEC032025', 'ABK042023', 'OFC042026', 'ZVM062022', 'ADO112023', 'AHD062022', 'ZSY062022', 'SBT032025', 'ZDX112021', 'ODF062024', 'DBX032022', 'AWX122024', 'MPA032026', 'DBT042023', 'ADM062025', 'TAB072023', 'DSL122024', 'BOO032022', 'KBN062023', 'APK032026', 'DTG052025', 'MAT022025', 'ABB092025', 'ODF0420241', 'SIB062025', 'ADY122023', 'ICS032022', 'SNC022026', 'LAN012026', 'QLC092022', 'SNF092022', 'PDY092024', 'DTG022025', 'ABR092025', 'GVM062022', 'GDF032022', 'VNB032025', 'ZBA042022', 'COM032023', 'SDS122025', 'ZFN032022', 'NFI042024', 'ASM0220223', 'TDM052022', 'OVM012024', 'RST062023', 'GIT092025', 'OFC032026', 'AEC082022', 'TER102023', 'CCI012025', 'ATR122022', 'VBR062025', 'ANS032024', 'ASF012023', 'ABA092022', 'RMQ082024', 'ODS052024', 'BAK092023', 'ZWB072025', 'ACS042023', 'ZLA112022', 'RBK072025', 'ACF082023', 'GVA092025', 'MBI042022', 'ODI032024', 'ADB112022', 'GLU062021', 'AST072024', 'SOP072023', 'NBU032025', 'GCC052024', 'ALM012024', 'CMR022024', 'GDU102023', 'ZRM082023', 'TDO042024', 'ADF062021', 'AMW112024', 'AQS012023', 'VMW102024', 'ADP122022', 'APP022025', 'AEM072022', 'AAP092024', 'GBA032023', 'UIP072021', 'CRW122025', 'MFB062025', 'GWF092023', 'ARS112024', 'GDP042022', 'AAR072022', 'AAT052023', 'GBQ102022', 'SFI122022', 'PBI082024', 'GFU012023', 'AAF112024', 'GDM082023', 'DSW122024'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 9c336b3..03a866f 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.6.0' + assert ctm_python_client.__version__ == '2.6.1' From 7fc73e185befedfde3e2cc93d0d557aaeeb37c17 Mon Sep 17 00:00:00 2001 From: ybauming_bmcgit Date: Sun, 12 Apr 2026 21:48:20 +0300 Subject: [PATCH 2/2] WBL-378889 Control-M Integrations Factory up to April 2026 --- src/aapi/integration_factory/connection_profiles.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py index 60784a5..88a418b 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -1562,7 +1562,7 @@ class ConnectionProfileApacheKafkaViaConfluent(ConnectionProfile): '_aapi_repr_': 'API Key ID'}) api_key_secret: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'API Key Secret'}) - o_auth_2.0_token_endpoint: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'OAuth 2.0 Token Endpoint'}) + o_auth_2_0_token_endpoint: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'OAuth 2.0 Token Endpoint'}) 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={