diff --git a/setup.py b/setup.py index 735d6b8..9e4ef57 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.4.9", + version="2.4.10", 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 0d50d56..0babfde 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -3,7 +3,9 @@ import attrs import typing import enum -from aapi import * +from aapi.bases import AAPIObject +from aapi.job import Job +from aapi.connectionprofile import ConnectionProfile @attrs.define @@ -30,24 +32,6 @@ class ConnectionProfileIBMDataStageLinux(ConnectionProfile): '_aapi_repr_': 'DSJOB Path'}) -@attrs.define -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 ConnectionProfileAwsDataSync(ConnectionProfile): @@ -72,6 +56,24 @@ class ConnectionProfileAwsDataSync(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +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 ConnectionProfileAnsibleAWX(ConnectionProfile): @@ -144,22 +146,12 @@ class ConnectionProfileAwsMainframeModernization(ConnectionProfile): '_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 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'}) + 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'}) @@ -182,6 +174,22 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPDeploymentManager(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Manager URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileWebServicesREST(ConnectionProfile): @@ -397,6 +405,20 @@ class ConnectionProfileAirbyte(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileCircleCI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:CircleCI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:CircleCI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + circle_c_i_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'CircleCI URL'}) + api_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPVM(ConnectionProfile): @@ -413,20 +435,6 @@ class ConnectionProfileGCPVM(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileCircleCI(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:CircleCI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:CircleCI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - circle_c_i_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'CircleCI URL'}) - api_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsAppRunner(ConnectionProfile): @@ -630,6 +638,10 @@ class ConnectionProfileAwsSNS(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) 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'}) @@ -684,6 +696,28 @@ class ConnectionProfileUIPath(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileDatadog(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Datadog', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Datadog'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + datadog_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datadog URL'}) + api_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key'}) + application_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application Key'}) + 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 ConnectionProfileAlteryxTrifacta(ConnectionProfile): @@ -701,25 +735,25 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): @attrs.define -class ConnectionProfileSnowflakeIdP(ConnectionProfile): +class ConnectionProfileAwsSQS(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS SQS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS SQS'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - 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'}) + aws_sqs_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS SQS URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -747,25 +781,25 @@ class ConnectionProfileIBMDataStageWindows(ConnectionProfile): @attrs.define -class ConnectionProfileAwsSQS(ConnectionProfile): +class ConnectionProfileSnowflakeIdP(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS SQS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS SQS'}) + _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}) - aws_sqs_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS SQS URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + 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 @@ -790,6 +824,8 @@ class ConnectionProfileAwsGlue(ConnectionProfile): object_name: str = attrs.field(metadata={'_aapi_name_': True}) glue_url: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Glue url'}) + aws_logs_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Logs 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={ @@ -800,8 +836,18 @@ class ConnectionProfileAwsGlue(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) iam_role: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) 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 @@ -867,23 +913,29 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): @attrs.define -class ConnectionProfileDatabricks(ConnectionProfile): +class ConnectionProfileAwsAppFlow(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS AppFlow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS AppFlow'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - databricks_workspace_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks workspace url'}) - databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks personal access token'}) + aws_appflow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Appflow 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: 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'}) - 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 @@ -917,29 +969,23 @@ class ConnectionProfileAzureBatchAccounts(ConnectionProfile): @attrs.define -class ConnectionProfileAwsAppFlow(ConnectionProfile): +class ConnectionProfileDatabricks(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS AppFlow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS AppFlow'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_appflow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Appflow 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: 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'}) + databricks_workspace_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks workspace url'}) + databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks personal access token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + 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 @@ -1076,22 +1122,6 @@ class ConnectionProfileAzureVM(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileDBT(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT URL'}) - dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Token'}) - account_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account ID'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsAthena(ConnectionProfile): @@ -1114,6 +1144,22 @@ class ConnectionProfileAwsAthena(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileDBT(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT URL'}) + dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Token'}) + account_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account ID'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileApacheNiFi(ConnectionProfile): @@ -1132,20 +1178,6 @@ class ConnectionProfileApacheNiFi(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): @@ -1174,6 +1206,38 @@ 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 ConnectionProfileSAPBTP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:SAP BTP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:SAP BTP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + 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'}) + s_a_p_authentication_url: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'SAP Authentication URL'}) + trigger_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger URL'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -1288,6 +1352,10 @@ class ConnectionProfileAwsMWAA(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) 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'}) @@ -1404,30 +1472,6 @@ class ConnectionProfileVMwareByBroadcom(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileDatadog(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Datadog', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Datadog'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - datadog_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datadog URL'}) - site: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Site'}) - api_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Key'}) - application_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application Key'}) - 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 ConnectionProfileMicroFocusLinux(ConnectionProfile): @@ -1540,32 +1584,6 @@ class ConnectionProfileAzureMachineLearning(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileOCIDataFlow(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Data Flow URL'}) - oci_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User OCID'}) - tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenancy OCID'}) - fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fingerprint'}) - private_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Private Key'}) - config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Config File Path'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureDataFactory(ConnectionProfile): @@ -1600,6 +1618,32 @@ class ConnectionProfileAzureDataFactory(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileOCIDataFlow(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Data Flow URL'}) + oci_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User OCID'}) + tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenancy OCID'}) + fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fingerprint'}) + private_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Private Key'}) + config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Config File Path'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsStepFunctions(ConnectionProfile): @@ -1618,6 +1662,34 @@ class ConnectionProfileAwsStepFunctions(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) iam_role: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + 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 ConnectionProfileInformaticaCS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Login URL'}) + base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Base URL'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1642,24 +1714,6 @@ class WebServiceAuthenticationBasic(AAPIObject): kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationBasic'}) -@attrs.define -class ConnectionProfileInformaticaCS(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Login URL'}) - base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Base URL'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileOCIDataScience(ConnectionProfile): @@ -1740,6 +1794,7 @@ class ConnectionProfileAzureDatabricks(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) + @attrs.define class ConnectionProfileTerraform(ConnectionProfile): @@ -1754,7 +1809,6 @@ class ConnectionProfileTerraform(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) - @attrs.define class ConnectionProfileAwsECS(ConnectionProfile): @@ -1775,6 +1829,10 @@ class ConnectionProfileAwsECS(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) 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'}) @@ -1837,24 +1895,6 @@ class ConnectionProfileAzureLogicApps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileQlikCloud(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Qlik API URL'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - api_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileRabbitMQ(ConnectionProfile): @@ -1873,6 +1913,24 @@ class ConnectionProfileRabbitMQ(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileQlikCloud(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Qlik API URL'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + api_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileJenkins(ConnectionProfile): @@ -2033,28 +2091,6 @@ class ConnectionProfileMicrosoftPowerBISP(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): @@ -2083,6 +2119,28 @@ class ConnectionProfileOCIDataIntegration(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsDataPipeline(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Pipeline URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileMicroFocusWindows(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index c3d5515..023b213 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -3,7 +3,9 @@ import attrs import typing import enum -from aapi import * +from aapi.bases import AAPIObject +from aapi.job import Job +from aapi.connectionprofile import ConnectionProfile @attrs.define @@ -40,28 +42,6 @@ class JobIBMDataStageLinux(Job): '_aapi_repr_': 'Empty1'}) -@attrs.define -class JobAlibabaECS(Job): - - _type: str = attrs.field(init=False, default='Job:Alibaba ECS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alibaba ECS'}) - 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'}) - instance_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Instance ID'}) - 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'}) - verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Interval'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsDataSync(Job): @@ -84,6 +64,28 @@ class JobAwsDataSync(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAlibabaECS(Job): + + _type: str = attrs.field(init=False, default='Job:Alibaba ECS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alibaba ECS'}) + 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'}) + instance_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Instance ID'}) + 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'}) + verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Interval'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAnsibleAWX(Job): @@ -272,28 +274,6 @@ class JobAwsMainframeModernization(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobGCPDeploymentManager(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Name'}) - yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Yaml Config Content'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureDevOps(Job): @@ -324,6 +304,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 JobWebServicesREST(Job): @@ -526,6 +528,30 @@ class JobAirbyte(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobCircleCI(Job): + + _type: str = attrs.field(init=False, default='Job:CircleCI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:CircleCI'}) + 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'}) + project_slug: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Slug'}) + workflow_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow ID'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobGCPVM(Job): @@ -558,30 +584,6 @@ class JobGCPVM(Job): '_aapi_repr_': 'Get Logs'}) -@attrs.define -class JobCircleCI(Job): - - _type: str = attrs.field(init=False, default='Job:CircleCI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:CircleCI'}) - 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'}) - project_slug: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project Slug'}) - workflow_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workflow ID'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsAppRunner(Job): @@ -828,6 +830,38 @@ class JobUIPath(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobDatadog(Job): + + _type: str = attrs.field(init=False, default='Job:Datadog', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Datadog'}) + 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'}) + workflow_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow ID'}) + workflow_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow Parameters'}) + synthetics_test_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Synthetics Test Type'}) + test_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Test Parameters'}) + event_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Event Parameters'}) + incident_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Incident ID'}) + incident_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Incident Parameters'}) + delay_logs_retrieval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delay Logs Retrieval'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAlteryxTrifacta(Job): @@ -850,6 +884,77 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobAwsSQS(Job): + + _type: str = attrs.field(init=False, default='Job:AWS SQS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS SQS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action Type'}) + queue_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + queue_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue URL'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) + delay_seconds: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delay Seconds'}) + message_deduplication_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Deduplication ID'}) + message_group_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Group ID'}) + message_attributes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Attributes'}) + attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) + attribute1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) + attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) + attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) + attribute2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) + attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) + attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) + attribute3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) + attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) + + +@attrs.define +class 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): @@ -938,77 +1043,6 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) - - -@attrs.define -class JobAwsSQS(Job): - - _type: str = attrs.field(init=False, default='Job:AWS SQS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS SQS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action Type'}) - queue_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - queue_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Queue URL'}) - message_body: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Body'}) - delay_seconds: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delay Seconds'}) - message_deduplication_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Deduplication ID'}) - message_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Group ID'}) - message_attributes: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Attributes'}) - attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) - attribute1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) - attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) - attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) - attribute2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) - attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) - attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) - attribute3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) - attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) - - @attrs.define class JobGCPDataprep(Job): @@ -1039,8 +1073,14 @@ class JobAwsGlue(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) + glue_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Type'}) glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Glue Job Name'}) + glue_workflow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Workflow Name'}) + crawler_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Crawler Name'}) glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Glue Job Arguments'}) arguments: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1049,6 +1089,10 @@ class JobAwsGlue(Job): '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Failure Tolerance'}) + output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output Job Logs'}) + log_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Log type'}) @attrs.define @@ -1126,21 +1170,25 @@ class JobAwsCloudFormation(Job): @attrs.define -class JobDatabricks(Job): +class JobAwsAppFlow(Job): - _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) + _type: str = attrs.field(init=False, default='Job:AWS AppFlow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS AppFlow'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks Job ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotency Token'}) - show_tasks_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Tasks Output'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + flow_name__iam: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name - IAM'}) + flow_name__assume_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name - Assume Role'}) + trigger_flow_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Flow with Idempotency Token'}) + client_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Token'}) 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={ @@ -1188,25 +1236,21 @@ class JobAzureBatchAccounts(Job): @attrs.define -class JobAwsAppFlow(Job): +class JobDatabricks(Job): - _type: str = attrs.field(init=False, default='Job:AWS AppFlow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS AppFlow'}) + _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) - flow_name__iam: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name - IAM'}) - flow_name__assume_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name - Assume Role'}) - trigger_flow_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trigger Flow with Idempotency Token'}) - client_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Token'}) + databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks Job ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Idempotency Token'}) + show_tasks_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Tasks 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={ @@ -1369,28 +1413,6 @@ class JobAzureVM(Job): '_aapi_repr_': 'Get Logs'}) -@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): @@ -1439,6 +1461,28 @@ class JobAwsAthena(Job): '_aapi_repr_': 'NoPerm'}) +@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 JobApacheNiFi(Job): @@ -1463,6 +1507,23 @@ class JobApacheNiFi(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureServiceBus(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Bus Namespace'}) + queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) + message_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Format'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) + + @attrs.define class JobFivetran(Job): @@ -1488,20 +1549,35 @@ class JobFivetran(Job): @attrs.define -class JobAzureServiceBus(Job): +class JobSAPBTP(Job): - _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) + _type: str = attrs.field(init=False, default='Job:SAP BTP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:SAP BTP'}) 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_': 'Queue\Topic 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'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + s_a_p_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SAP Job Name'}) + job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Name'}) + job_description: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Description'}) + job_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job URL'}) + http_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Method'}) + notification_on_success: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Notification On Success'}) + notification_on_error: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Notification On Error'}) + job_data: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Data'}) + 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 @@ -1910,36 +1986,6 @@ class JobVMwareByBroadcom(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobDatadog(Job): - - _type: str = attrs.field(init=False, default='Job:Datadog', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Datadog'}) - 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'}) - workflow_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workflow ID'}) - workflow_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workflow Parameters'}) - synthetics_test_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Synthetics Test Type'}) - test_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Test Parameters'}) - event_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Event Parameters'}) - incident_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Incident Parameters'}) - delay_logs_retrieval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delay Logs Retrieval'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobMicroFocusLinux(Job): @@ -2056,24 +2102,6 @@ class JobAzureMachineLearning(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobOCIDataFlow(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Compartment OCID'}) - application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application OCID'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureDataFactory(Job): @@ -2100,6 +2128,24 @@ class JobAzureDataFactory(Job): '_aapi_repr_': 'Reference Pipeline Run ID'}) +@attrs.define +class JobOCIDataFlow(Job): + + _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Compartment OCID'}) + application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application OCID'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsStepFunctions(Job): @@ -2122,6 +2168,40 @@ class JobAwsStepFunctions(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobInformaticaCS(Job): + + _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + task_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Type'}) + use_federation_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Use Federation ID'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Name'}) + folder_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Path'}) + taskflow_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Taskflow Job Name'}) + task_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'TaskFlow URL'}) + rerun_suspended_taskflow: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Suspended Taskflow'}) + rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Run ID'}) + input_fields: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Fields'}) + call_back_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Call Back URL'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobWebServicesSOAP(Job): @@ -2158,40 +2238,6 @@ class SoapRequest(AAPIObject): '_aapi_repr_': 'Append Response'}) -@attrs.define -class JobInformaticaCS(Job): - - _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - task_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Type'}) - use_federation_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Use Federation ID'}) - task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Name'}) - folder_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Path'}) - taskflow_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Taskflow Job Name'}) - task_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'TaskFlow URL'}) - rerun_suspended_taskflow: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Suspended Taskflow'}) - rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Run ID'}) - input_fields: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Input Fields'}) - call_back_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Call Back URL'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobOCIDataScience(Job): @@ -2254,6 +2300,7 @@ class JobAzureDatabricks(Job): '_aapi_repr_': 'Failure Tolerance'}) + @attrs.define class JobTerraform(Job): @@ -2280,7 +2327,6 @@ class JobTerraform(Job): '_aapi_repr_': 'Failure Tolerance'}) - @attrs.define class JobAwsECS(Job): @@ -2397,26 +2443,6 @@ class JobAzureLogicApps(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobQlikCloud(Job): - - _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - reload_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reload Type'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Print Log to Output'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) - - @attrs.define class JobRabbitMQ(Job): @@ -2443,6 +2469,26 @@ class JobRabbitMQ(Job): '_aapi_repr_': 'Queue'}) +@attrs.define +class JobQlikCloud(Job): + + _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + reload_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reload Type'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Print Log to Output'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + + @attrs.define class JobJenkins(Job): @@ -2711,32 +2757,6 @@ class JobMicrosoftPowerBISP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsDataPipeline(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Data Pipeline'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - pipeline_unique_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Unique ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - trigger_created_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trigger Created Pipeline'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobOCIDataIntegration(Job): @@ -2763,6 +2783,32 @@ class JobOCIDataIntegration(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAwsDataPipeline(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Data Pipeline'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + pipeline_unique_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Unique ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + trigger_created_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Created Pipeline'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobMicroFocusWindows(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 2051da5..657f366 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.4.9' +__version__ = '2.4.10' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 3e52445..93c619c 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 = ['ATR122022', 'NFI042024', 'ALM012024', 'TER102023', 'CCI012025', 'UIP072021', 'SOP072023', 'AEC082022', 'AMM082023', 'SFI122022', 'GVM062022', 'VNB032025', 'FVT032025', 'DSL122024', 'AAF112024', 'ADB112022', 'PDY092024', 'ASQ032024', 'ANS032024', 'GDQ112023', 'GWF092023', 'GBQ102022', 'ASM0220223', 'KBN062023', 'ADF062021', 'BOO032022', 'ICS032022', 'DBT042023', 'GDP042022', 'ZSY062022', 'ZRM082023', 'ZFN032022', 'NBU032025', 'AWX122024', 'COM032023', 'ASB012025', 'TAB072023', 'ADP122022', 'GDF032022', 'ODI032024', 'GCR042024', 'JEN022024', 'ZDX112021', 'ODS052024', 'ZVM062022', 'GDM082023', 'MFL022023', 'TDO042024', 'DBX032022', 'AAR072022', 'ODF0420241', 'ACS042023', 'GLU062021', 'GDU102023', 'DSW122024', 'AMW112024', 'QLC092022', 'BEC032025', 'VMW102024', 'ADS102024', 'ZML022023', 'ADO112023', 'GDR052023', 'AHD062022', 'MBI042022', 'APP022025', 'ADY122023', 'MFW022023', 'TDM052022', 'ZLA112022', 'ABK042023', 'DTG022025', 'BAK092023', 'SNF092022', 'PBI082024', 'RST062023', 'GCC052024', 'ABY122023', 'AQS012023', 'GFU012023', 'AAT052023', 'RMQ082024', 'CMR022024', 'ABA092022', 'ACF082023', 'ZBA042022', 'ARS112024', 'AST072024', 'OVM012024', 'AEM072022', 'AAP092024', 'ASF012023', 'GBA032023'] +IF_PLUGINS = ['TDM052022', 'SBT032025', 'ADY122023', 'ADO112023', 'PDY092024', 'ZSY062022', 'ADB112022', 'BEC032025', 'SNF092022', 'GBA032023', 'ADF062021', 'GDQ112023', 'COM032023', 'ATR122022', 'DBX032022', 'BOO032022', 'NFI042024', 'ASQ032024', 'CCI012025', 'ADP122022', 'SOP072023', 'AEM072022', 'NBU032025', 'VNB032025', 'GDR052023', 'MFL022023', 'ASM0220223', 'GLU062021', 'ZVM062022', 'TER102023', 'SFI122022', 'AMM082023', 'ABY122023', 'MBI042022', 'AAT052023', 'BAK092023', 'KBN062023', 'AAR072022', 'ZRM082023', 'OVM012024', 'RST062023', 'DSL122024', 'AHD062022', 'GDP042022', 'VMW102024', 'ASB012025', 'GFU012023', 'GDM082023', 'GBQ102022', 'ASF012023', 'RMQ082024', 'DSW122024', 'ARS112024', 'GCR042024', 'FVT032025', 'GVM062022', 'ABA092022', 'ODS052024', 'ADS102024', 'APP022025', 'AWX122024', 'ANS032024', 'TDO042024', 'JEN022024', 'GDU102023', 'QLC092022', 'ACF082023', 'GDF032022', 'MFW022023', 'AST072024', 'ICS032022', 'UIP072021', 'DBT042023', 'DTG022025', 'ZFN032022', 'AAP092024', 'ZLA112022', 'TAB072023', 'ZDX112021', 'ODI032024', 'ACS042023', 'AEC082022', 'ODF0420241', 'ZBA042022', 'ALM012024', 'AMW112024', 'GWF092023', 'ABK042023', 'AQS012023', 'CMR022024', 'ZML022023', 'DTG052025', 'GCC052024', 'PBI082024', 'AAF112024'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 2cded1f..a3797b7 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.4.9' + assert ctm_python_client.__version__ == '2.4.10'