From 206329a2b57645b893c143770d491e2cadf56253 Mon Sep 17 00:00:00 2001 From: "Semo Eshed, Irit" Date: Wed, 17 Dec 2025 12:48:41 +0200 Subject: [PATCH] Control-M Integrations Factory up to Nov. 2025 --- setup.py | 2 +- .../connection_profiles.py | 522 +++++++------ src/aapi/integration_factory/jobs.py | 710 +++++++++--------- src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/ext/autogen.py | 2 +- tests/test_sanity.py | 2 +- 6 files changed, 654 insertions(+), 586 deletions(-) diff --git a/setup.py b/setup.py index 60ed558..05eb796 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ name="ctm-python-client", packages=find_packages(where="src"), package_dir={"": "src"}, - version="2.5.8", + version="2.5.9", 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 ff6b0fa..c896cf4 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -82,22 +82,6 @@ class ConnectionProfileAwsDynamoDB(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileGCPDeploymentManager(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Manager URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureDevOps(ConnectionProfile): @@ -130,6 +114,22 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPDeploymentManager(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Manager URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsEC2(ConnectionProfile): @@ -276,24 +276,6 @@ class ConnectionProfileGCPDataFusion(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileUIPath(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Name'}) - tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Url'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - app_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App Secret'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileDatadog(ConnectionProfile): @@ -316,6 +298,24 @@ class ConnectionProfileDatadog(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileUIPath(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Name'}) + tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Url'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + app_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App Secret'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsGlue(ConnectionProfile): @@ -398,6 +398,40 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Subscription ID'}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Specify Managed Identity Client ID'}) + managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Managed Identity Client ID'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Login url'}) + function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App Web Site'}) + 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 ConnectionProfileAzureBatchAccounts(ConnectionProfile): @@ -460,40 +494,6 @@ class ConnectionProfileAwsAppFlow(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureFunctions(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login url'}) - function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App Web Site'}) - 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): @@ -536,6 +536,38 @@ class ConnectionProfileTableau(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileGCPDataplex(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Dataplex URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection timeout'}) + + +@attrs.define +class ConnectionProfileGCPComposer(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + composer_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Composer URL'}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureVM(ConnectionProfile): @@ -570,38 +602,6 @@ class ConnectionProfileAzureVM(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileGCPDataplex(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP Dataplex URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection timeout'}) - - -@attrs.define -class ConnectionProfileGCPComposer(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - composer_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Composer URL'}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileApacheNiFi(ConnectionProfile): @@ -679,61 +679,61 @@ class ConnectionProfileGCPDataflow(ConnectionProfile): @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 -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 @@ -852,6 +852,8 @@ class ConnectionProfileCommunicationSuite(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Communication Suite', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Communication Suite'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) + platform: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Platform'}) microsoft_teams_webhook_url: str = attrs.field( kw_only=True, default=None, metadata={'_aapi_repr_': 'Microsoft Teams Webhook URL'}) slack_webhook_url: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1135,35 +1137,35 @@ class ConnectionProfileAutomationAnywhere(ConnectionProfile): @attrs.define -class ConnectionProfileRabbitMQ(ConnectionProfile): +class ConnectionProfileJenkins(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:RabbitMQ', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Jenkins'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'RabbitMQ URL'}) - port: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Port'}) + jenkins_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Jenkins URL'}) username: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) + user_api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User API Token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @attrs.define -class ConnectionProfileJenkins(ConnectionProfile): +class ConnectionProfileRabbitMQ(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Jenkins'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - jenkins_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Jenkins URL'}) + rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RabbitMQ URL'}) + port: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Port'}) username: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Username'}) - user_api_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User API Token'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1248,26 +1250,6 @@ class ConnectionProfileVeeamBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - user_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Name'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) - - @attrs.define class ConnectionProfileAzureBackup(ConnectionProfile): @@ -1296,6 +1278,26 @@ class ConnectionProfileAzureBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Name'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + + @attrs.define class ConnectionProfileSnowflake(ConnectionProfile): @@ -1958,6 +1960,28 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileSnowflakeIdP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Identifier'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + idp_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IDP URL'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + + @attrs.define class ConnectionProfileIBMDataStageWindows(ConnectionProfile): @@ -1982,28 +2006,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 ConnectionProfileAwsSQS(ConnectionProfile): @@ -2104,22 +2106,6 @@ class ConnectionProfileDatabricks(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) -@attrs.define -class ConnectionProfileDBT(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT URL'}) - dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Token'}) - account_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account ID'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsAthena(ConnectionProfile): @@ -2143,15 +2129,17 @@ class ConnectionProfileAwsAthena(ConnectionProfile): @attrs.define -class ConnectionProfileFivetran(ConnectionProfile): +class ConnectionProfileDBT(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - 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'}) + dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT URL'}) + dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Token'}) + account_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account ID'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -2184,6 +2172,20 @@ class ConnectionProfileAzureServiceBus(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileFivetran(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fivetran Base URL'}) + api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Base 64 Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -2312,12 +2314,46 @@ class ConnectionProfileMicroFocusLinux(ConnectionProfile): '_aapi_repr_': 'Runtime Environment'}) additional_micro_focus_settings_script: str = attrs.field( kw_only=True, default=None, metadata={'_aapi_repr_': 'Additional Micro Focus Settings Script'}) + enable_cluster_mode: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Enable Cluster Mode'}) + cluster_host: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Host'}) + cluster_port: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Port'}) + casclsec_is_enabled_on_micro_focus: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Casclsec is enabled on MicroFocus'}) + micro_focus_authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Micro Focus Authentication'}) + user_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User ID'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) run_as: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Run As'}) run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'RunAs-Pass'}) +@attrs.define +class ConnectionProfileCrewAI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:CrewAI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:CrewAI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + crew_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Crew URL'}) + token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': '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 ConnectionProfileAzureResourceManager(ConnectionProfile): @@ -2417,22 +2453,6 @@ class ConnectionProfileTerraform(ConnectionProfile): -@attrs.define -class ConnectionProfileGCPFunctions(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - gcp_api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP API URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAtlassianBitbucket(ConnectionProfile): @@ -2457,6 +2477,22 @@ class ConnectionProfileAtlassianBitbucket(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + gcp_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP API URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureLogicApps(ConnectionProfile): @@ -2537,6 +2573,28 @@ class ConnectionProfileOCIVM(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsDataPipeline(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Pipeline URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileOCIDataIntegration(ConnectionProfile): @@ -2565,28 +2623,6 @@ class ConnectionProfileOCIDataIntegration(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsDataPipeline(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Pipeline URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileGCPCloudRun(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 00d3ffb..756cc48 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -108,28 +108,6 @@ class JobAwsDynamoDB(Job): '_aapi_repr_': 'Failure Tolarance '}) -@attrs.define -class JobGCPDeploymentManager(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Name'}) - yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Yaml Config Content'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureDevOps(Job): @@ -160,6 +138,28 @@ class JobAzureDevOps(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPDeploymentManager(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Name'}) + yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Yaml Config Content'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsEC2(Job): @@ -362,30 +362,6 @@ class JobGCPDataFusion(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobUIPath(Job): - - _type: str = attrs.field(init=False, default='Job:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - folder_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Name'}) - folder_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Id'}) - process_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Process Name'}) - robot_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Name'}) - robot_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Id'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobDatadog(Job): @@ -418,6 +394,32 @@ 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): @@ -481,7 +483,7 @@ class JobApacheAirflow(Job): json: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'JSON'}) switch_to_rerun: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Switch To Rerun'}) + '_aapi_repr_': 'Switch to Rerun'}) keep_run_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Keep Run ID'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ @@ -522,6 +524,34 @@ class JobAwsCloudFormation(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_app: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App'}) + azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource'}) + azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource Scope'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Input Parameters'}) + function_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Type'}) + verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Intervall'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) + + @attrs.define class JobAzureBatchAccounts(Job): @@ -588,34 +618,6 @@ class JobAwsAppFlow(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_app: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App'}) - azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Resource'}) - azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Resource Scope'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - function_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Type'}) - verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Intervall'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API-VERSION'}) - - @attrs.define class JobAwsEMR(Job): @@ -664,36 +666,6 @@ class JobTableau(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureVM(Job): - - _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - vm_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'VM Name'}) - operation: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Operation'}) - tag_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tag Name'}) - tag_value: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tag Value'}) - input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Input Parameters'}) - verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Interval'}) - delete_vm_os_disk: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delete VM OS Disk'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) - api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API-VERSION'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) - - @attrs.define class JobGCPDataplex(Job): @@ -746,6 +718,36 @@ class JobGCPComposer(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureVM(Job): + + _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + vm_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'VM Name'}) + operation: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Operation'}) + tag_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Name'}) + tag_value: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Value'}) + input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Parameters'}) + verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Interval'}) + delete_vm_os_disk: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delete VM OS Disk'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) + + @attrs.define class JobApacheNiFi(Job): @@ -872,32 +874,6 @@ 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): @@ -928,6 +904,32 @@ 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): @@ -1064,6 +1066,8 @@ class JobVMwareByBroadcom(Job): '_aapi_repr_': 'Datacenter'}) cluster: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Cluster'}) + template_library_item_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Template Library Item ID'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) placement_json: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1078,8 +1082,6 @@ class JobVMwareByBroadcom(Job): '_aapi_repr_': 'Cores Per Socket'}) size_in_mi_b: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Size In MiB'}) - template_library_item_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Template Library Item ID'}) snapshot_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Snapshot Name'}) snapshot_description: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1090,6 +1092,8 @@ class JobVMwareByBroadcom(Job): '_aapi_repr_': 'Quiesce'}) snapshot_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Snapshot ID'}) + vm_mo_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'VM MoId'}) release_schema: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Release Schema'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1440,32 +1444,6 @@ class JobAutomationAnywhere(Job): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class JobRabbitMQ(Job): - - _type: str = attrs.field(init=False, default='Job:RabbitMQ', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:RabbitMQ'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - vhost: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Vhost'}) - exchange: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Exchange'}) - routing_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Routing Key'}) - message_to_publish: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message to Publish'}) - message_encoding: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Encoding'}) - properties: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Properties'}) - queue: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue'}) - - @attrs.define class JobJenkins(Job): @@ -1492,6 +1470,32 @@ class JobJenkins(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobRabbitMQ(Job): + + _type: str = attrs.field(init=False, default='Job:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:RabbitMQ'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + vhost: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Vhost'}) + exchange: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Exchange'}) + routing_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Routing Key'}) + message_to_publish: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message to Publish'}) + message_encoding: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Encoding'}) + properties: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Properties'}) + queue: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue'}) + + @attrs.define class JobMicrosoftFabric(Job): @@ -1574,32 +1578,6 @@ class JobVeeamBackup(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobMicrosoftPowerBI(Job): - - _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) - dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - - @attrs.define class JobAzureBackup(Job): @@ -1638,6 +1616,32 @@ class JobAzureBackup(Job): '_aapi_repr_': 'Failure Tolerance '}) +@attrs.define +class JobMicrosoftPowerBI(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) + workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace Name'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + + @attrs.define class JobSnowflake(Job): @@ -2375,69 +2379,35 @@ class JobAwsLambda(Job): connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - function_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Version'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log to Output'}) - - -@attrs.define -class JobAlteryxTrifacta(Job): - - _type: str = attrs.field(init=False, default='Job:Alteryx Trifacta', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alteryx Trifacta'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) - rerun_with_new_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun With New Idempotency Token'}) - idempotent_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotent Token'}) - retrack_job_status: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retrack Job Status'}) - run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run-ID'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) + '_aapi_repr_': 'Function Name'}) + function_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Version'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log to Output'}) + + +@attrs.define +class JobAlteryxTrifacta(Job): + + _type: str = attrs.field(init=False, default='Job:Alteryx Trifacta', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alteryx Trifacta'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + rerun_with_new_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun With New Idempotency Token'}) + idempotent_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Idempotent Token'}) + retrack_job_status: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Retrack Job Status'}) + run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run-ID'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) @attrs.define @@ -2528,6 +2498,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 JobAwsSQS(Job): @@ -2633,28 +2637,6 @@ class JobDatabricks(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobDBT(Job): - - _type: str = attrs.field(init=False, default='Job:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Job Id'}) - run_comment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run Comment'}) - override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Override Job Commands'}) - define_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Define Commands'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsAthena(Job): @@ -2704,23 +2686,21 @@ class JobAwsAthena(Job): @attrs.define -class JobFivetran(Job): +class JobDBT(Job): - _type: str = attrs.field(init=False, default='Job:Fivetran', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Fivetran'}) + _type: str = attrs.field(init=False, default='Job:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - job_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Type'}) - connection_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection ID'}) - connection_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Name'}) - force_incremental_sync: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Force Incremental Sync'}) - transformation_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Transformation ID'}) + dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Job Id'}) + run_comment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Comment'}) + override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Override Job Commands'}) + define_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Define Commands'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2744,6 +2724,30 @@ class JobAzureServiceBus(Job): '_aapi_repr_': 'Message Body'}) +@attrs.define +class JobFivetran(Job): + + _type: str = attrs.field(init=False, default='Job:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + job_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Type'}) + connection_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection ID'}) + connection_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Name'}) + force_incremental_sync: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Force Incremental Sync'}) + transformation_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Transformation 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 JobAwsBatch(Job): @@ -2996,6 +3000,34 @@ class JobMicroFocusLinux(Job): kw_only=True, default=None, metadata={'_aapi_repr_': 'Modified JCL Path and Filename'}) +@attrs.define +class JobCrewAI(Job): + + _type: str = attrs.field(init=False, default='Job:CrewAI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:CrewAI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + crew_inputs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Crew Inputs'}) + additional_parameters_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Additional Parameters '}) + training_file_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Training File Name'}) + generate_artifact: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Generate Artifact'}) + task_webhook_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Webhook URL'}) + step_webhook_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Step Webhook URL'}) + crew_webhook_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Crew Webhook URL'}) + 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 JobAzureResourceManager(Job): @@ -3103,36 +3135,6 @@ class JobTerraform(Job): -@attrs.define -class JobGCPFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Location'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - function_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Parameters'}) - url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'URL Parameters'}) - body: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Body'}) - api_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Version'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) - - @attrs.define class JobAtlassianBitbucket(Job): @@ -3207,6 +3209,36 @@ class JobAtlassianBitbucket(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Location'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + function_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Parameters'}) + url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'URL Parameters'}) + body: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Body'}) + api_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Version'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) + + @attrs.define class JobAzureLogicApps(Job): @@ -3277,32 +3309,6 @@ class JobOCIVM(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobOCIDataIntegration(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - actions: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Actions'}) - workspace_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace OCID'}) - application_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application Key'}) - task_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Key'}) - task_run_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Run Name'}) - task_run_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Run Input Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsDataPipeline(Job): @@ -3329,6 +3335,32 @@ class JobAwsDataPipeline(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobOCIDataIntegration(Job): + + _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + actions: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Actions'}) + workspace_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace OCID'}) + application_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application Key'}) + task_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Key'}) + task_run_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Run Name'}) + task_run_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Run Input Parameters'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobGCPCloudRun(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index cc0e3e8..5c7f87f 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.5.8' +__version__ = '2.5.9' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 71fd799..22e94f8 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 = ['ADM062025', 'UIP072021', 'RST062023', 'GVM062022', 'GDF032022', 'GLU062021', 'ODI032024', 'BOO032022', 'OVM012024', 'ADS102024', 'AST072024', 'CCI012025', 'ATR122022', 'GIT092025', 'GDP042022', 'GCR042024', 'AAP092024', 'ICS032022', 'KBN062023', 'VBR062025', 'QLC092022', 'DSW122024', 'DTG022025', 'AAR072022', 'RMQ082024', 'GBQ102022', 'GDM082023', 'TDO042024', 'ACS042023', 'AMM082023', 'ABA092022', 'ZVM062022', 'ZBA042022', 'ODS052024', 'AQS012023', 'FVT032025', 'COM032023', 'TDM052022', 'ANS032024', 'RBK072025', 'BEC032025', 'AMW112024', 'AEC082022', 'CMR022024', 'ODF0420241', 'SFI122022', 'TAB072023', 'MFL022023', 'SOP072023', 'MFB062025', 'ADY122023', 'ABR092025', 'ARS112024', 'ZFN032022', 'SNF092022', 'ABY122023', 'ABK042023', 'APP022025', 'JEN022024', 'ASQ032024', 'ADF062021', 'AEM072022', 'NFI042024', 'DSL122024', 'ZLA112022', 'ABB092025', 'TER102023', 'SBT032025', 'AAF112024', 'AHD062022', 'ADP122022', 'GDR052023', 'ZDX112021', 'DTG052025', 'ZRM082023', 'ACF082023', 'AWX122024', 'MFW022023', 'ALM012024', 'PBI082024', 'GVA092025', 'DBX032022', 'JCP102025', 'GWF092023', 'MBI042022', 'GCC052024', 'GBA032023', 'ADO112023', 'VNB032025', 'BAK092023', 'ASF012023', 'ZWB072025', 'AAT052023', 'GDQ112023', 'GEA072025', 'DBT042023', 'ADB112022', 'VMW102024', 'MAT022025', 'GDU102023', 'ZML022023', 'NBU032025', 'ASM0220223', 'PDY092024', 'ZSY062022', 'ASB012025', 'GFU012023'] +IF_PLUGINS = ['ADY122023', 'ADS102024', 'ADB112022', 'ODI032024', 'ICS032022', 'MFW022023', 'GIT092025', 'DBT042023', 'ATR122022', 'AAF112024', 'GDR052023', 'TER102023', 'RBK072025', 'GEA072025', 'UIP072021', 'ZBA042022', 'ZLA112022', 'ASF012023', 'AAT052023', 'ZDX112021', 'ASM0220223', 'ZML022023', 'ZWB072025', 'ZVM062022', 'ZSY062022', 'SNF092022', 'GCC052024', 'AQS012023', 'BOO032022', 'AHD062022', 'ABY122023', 'DTG022025', 'BAK092023', 'DTG052025', 'GDQ112023', 'OVM012024', 'TAB072023', 'ODS052024', 'JEN022024', 'GLU062021', 'GCR042024', 'ANS032024', 'AAP092024', 'RMQ082024', 'ADP122022', 'ACS042023', 'ZRM082023', 'AST072024', 'TDO042024', 'AWX122024', 'GVA092025', 'AAR072022', 'GDF032022', 'GFU012023', 'VMW102024', 'APP022025', 'GWF092023', 'GBA032023', 'AEC082022', 'AMW112024', 'GVM062022', 'ARS112024', 'ADO112023', 'CRW122025', 'CCI012025', 'ABB092025', 'ABK042023', 'MFB062025', 'ADF062021', 'DSW122024', 'MAT022025', 'GBQ102022', 'SOP072023', 'ABR092025', 'ASB012025', 'NBU032025', 'AEM072022', 'SBT032025', 'JCP102025', 'MFL022023', 'ACF082023', 'ABA092022', 'PBI082024', 'KBN062023', 'AMM082023', 'RST062023', 'COM032023', 'VBR062025', 'ALM012024', 'SFI122022', 'GDP042022', 'ASQ032024', 'PDY092024', 'TDM052022', 'CMR022024', 'VNB032025', 'ODF0420241', 'ADM062025', 'BEC032025', 'GDU102023', 'DSL122024', 'GDM082023', 'NFI042024', 'MBI042022', 'ZFN032022', 'QLC092022', 'DBX032022', 'FVT032025'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index d087414..5ffe880 100644 --- a/tests/test_sanity.py +++ b/tests/test_sanity.py @@ -2,6 +2,6 @@ def test_version_author(): import ctm_python_client assert ctm_python_client.__author__ == 'BMC Software' - assert ctm_python_client.__version__ == '2.5.8' + assert ctm_python_client.__version__ == '2.5.9'