diff --git a/setup.py b/setup.py index cb2190d..28418fe 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ name="ctm-python-client", packages=find_packages(where="src"), package_dir={"": "src"}, - version="2.3.2", + version="2.3.3", 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 651a5e9..d1b1cf0 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -1,4 +1,3 @@ - from __future__ import annotations import attrs import typing @@ -325,6 +324,20 @@ class ConnectionProfileAwsQuickSight(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileApplicationIntegratorAIKubernete1(ConnectionProfileApplicationIntegrator): + + _type: str = attrs.field(init=False, default='ConnectionProfile:ApplicationIntegrator:AI Kubernete1', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:ApplicationIntegrator:AI Kubernete1'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + ai_run_as: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Run As'}) + ai_run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-RunAs-Pass'}) + ai_kubectl_location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Kubectl Location'}) + + @attrs.define class ConnectionProfileAirbyte(ConnectionProfile): @@ -427,24 +440,6 @@ class ConnectionProfileAwsSNS(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 ConnectionProfileAwsLambda(ConnectionProfile): @@ -467,6 +462,24 @@ class ConnectionProfileAwsLambda(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileUIPath(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Name'}) + tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Url'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + app_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App Secret'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAlteryxTrifacta(ConnectionProfile): @@ -604,33 +617,33 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): @attrs.define -class ConnectionProfileAzureBatchAccounts(ConnectionProfile): +class ConnectionProfileAzureFunctions(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Batch Accounts', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Batch Accounts'}) + _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}) - azure_ad_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure AD url'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) + 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'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App 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'}) - batch_resource_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Resource url'}) - batch_account_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Account Name'}) - batch_region_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Region ID'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Login url'}) + function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App Web Site'}) + custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Custom App Key'}) @attrs.define @@ -648,33 +661,33 @@ class ConnectionProfileDatabricks(ConnectionProfile): @attrs.define -class ConnectionProfileAzureFunctions(ConnectionProfile): +class ConnectionProfileAzureBatchAccounts(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Functions'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Batch Accounts', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Batch Accounts'}) 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'}) + azure_ad_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure AD url'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Specify Managed Identity Client ID'}) managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Managed Identity Client ID'}) 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'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) client_secret: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Client Secret'}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login url'}) - function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App Web Site'}) - custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Custom App Key'}) + batch_resource_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch Resource url'}) + batch_account_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch Account Name'}) + batch_region_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch Region ID'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -779,6 +792,22 @@ 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): @@ -801,22 +830,6 @@ 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): @@ -901,6 +914,20 @@ class ConnectionProfileGCPBigQuery(ConnectionProfile): '_aapi_repr_': 'Service Account Key'}) +@attrs.define +class ConnectionProfileTalendDataManagement(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Talend Data Management', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Talend Data Management'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + personal_access_token_authorization: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Personal access token authorization'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + + @attrs.define class ConnectionProfileGCPDataproc(ConnectionProfile): @@ -917,20 +944,6 @@ class ConnectionProfileGCPDataproc(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileTalendDataManagement(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Talend Data Management', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Talend Data Management'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) - personal_access_token_authorization: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Personal access token authorization'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - - @attrs.define class ConnectionProfileAzureSynapse(ConnectionProfile): @@ -1071,34 +1084,6 @@ class ConnectionProfileAzureMachineLearning(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureDataFactory(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Data Factory', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Data Factory'}) - 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'}) - 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'}) - rest_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'REST Login url'}) - management_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Management url'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileOCIDataFlow(ConnectionProfile): @@ -1126,23 +1111,29 @@ class ConnectionProfileOCIDataFlow(ConnectionProfile): @attrs.define -class ConnectionProfileAwsStepFunctions(ConnectionProfile): +class ConnectionProfileAzureDataFactory(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Step Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Step Functions'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Data Factory', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Data Factory'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - step_functions_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Step Functions 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'}) + 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'}) + 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'}) + rest_login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'REST Login url'}) + management_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Management url'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1185,6 +1176,28 @@ class ConnectionProfileInformaticaCS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsStepFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Step Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Step Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + step_functions_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Step Functions 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 ConnectionProfileOCIDataScience(ConnectionProfile): @@ -1347,6 +1360,22 @@ class ConnectionProfileAzureLogicApps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileJenkins(ConnectionProfile): + + _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}) + 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'}) + 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 ConnectionProfileQlikCloud(ConnectionProfile): @@ -1366,19 +1395,23 @@ class ConnectionProfileQlikCloud(ConnectionProfile): @attrs.define -class ConnectionProfileJenkins(ConnectionProfile): +class ConnectionProfileMicrosoftPowerBI(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:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - 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'}) - 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'}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Name'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) @attrs.define @@ -1409,26 +1442,6 @@ class ConnectionProfileAzureBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - user_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Name'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) - - @attrs.define class ConnectionProfileSnowflake(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 2b44461..cb19493 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -1,4 +1,3 @@ - from __future__ import annotations import attrs import typing @@ -404,6 +403,24 @@ class JobAwsQuickSight(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobApplicationIntegratorAIKubernete1(JobApplicationIntegrator): + + _type: str = attrs.field(init=False, default='Job:ApplicationIntegrator:AI Kubernete1', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:ApplicationIntegrator:AI Kubernete1'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + ai_connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-ConnectionProfile'}) + ai_action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Action'}) + ai_yaml_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-YamlFile'}) + ai_resource_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-ResourceID'}) + + @attrs.define class JobAirbyte(Job): @@ -590,6 +607,24 @@ class JobAwsSNS(Job): push_attribute5_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Value'}) +@attrs.define +class JobAwsLambda(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Lambda', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Lambda'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + function_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Version'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log to Output'}) + + @attrs.define class JobUIPath(Job): @@ -614,24 +649,6 @@ class JobUIPath(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobAwsLambda(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Lambda', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Lambda'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - function_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Version'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log to Output'}) - - @attrs.define class JobAlteryxTrifacta(Job): @@ -869,6 +886,46 @@ class JobAwsCloudFormation(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_app: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function App'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Optional Input Parameters'}) + function_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Type'}) + verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Intervall'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + +@attrs.define +class JobDatabricks(Job): + + _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks Job ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Idempotency Token'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobAzureBatchAccounts(Job): @@ -909,46 +966,6 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) -@attrs.define -class JobDatabricks(Job): - - _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks Job ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotency Token'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - -@attrs.define -class JobAzureFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_app: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function App'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - function_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Type'}) - verification_poll_intervall: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Intervall'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsEMR(Job): @@ -1067,6 +1084,28 @@ 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): @@ -1115,28 +1154,6 @@ 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): @@ -1285,6 +1302,32 @@ class JobGCPBigQuery(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobTalendDataManagement(Job): + + _type: str = attrs.field(init=False, default='Job:Talend Data Management', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Talend Data Management'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + task_plan_execution: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task/Plan Execution'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Name'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + log_level: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Log Level'}) + bring_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bring logs to output'}) + task_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Polling Intervals'}) + plan_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Plan Name'}) + plan_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Plan Polling Intervals'}) + + @attrs.define class JobGCPDataproc(Job): @@ -1313,32 +1356,6 @@ class JobGCPDataproc(Job): '_aapi_repr_': 'Tolerance'}) -@attrs.define -class JobTalendDataManagement(Job): - - _type: str = attrs.field(init=False, default='Job:Talend Data Management', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Talend Data Management'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - task_plan_execution: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task/Plan Execution'}) - task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Name'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - log_level: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Log Level'}) - bring_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring logs to output'}) - task_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Polling Intervals'}) - plan_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Plan Name'}) - plan_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Plan Polling Intervals'}) - - @attrs.define class JobAzureSynapse(Job): @@ -1471,28 +1488,6 @@ class JobAzureMachineLearning(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureDataFactory(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Data Factory', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Data Factory'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - resource_group_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group Name'}) - data_factory_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Factory Name'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - 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 JobOCIDataFlow(Job): @@ -1512,21 +1507,21 @@ class JobOCIDataFlow(Job): @attrs.define -class JobAwsStepFunctions(Job): +class JobAzureDataFactory(Job): - _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) + _type: str = attrs.field(init=False, default='Job:Azure Data Factory', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Data Factory'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - execution_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Execution Name'}) - state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'State Machine ARN'}) + resource_group_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group Name'}) + data_factory_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Factory Name'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) - show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Execution Logs'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1603,6 +1598,28 @@ class JobInformaticaCS(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAwsStepFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + execution_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execution Name'}) + state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'State Machine ARN'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Execution Logs'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobOCIDataScience(Job): @@ -1797,6 +1814,30 @@ class JobAzureLogicApps(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobJenkins(Job): + + _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Parameters'}) + parameters: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) + add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Branch Name'}) + branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Branch Name'}) + 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 JobQlikCloud(Job): @@ -1818,27 +1859,29 @@ class JobQlikCloud(Job): @attrs.define -class JobJenkins(Job): +class JobMicrosoftPowerBI(Job): - _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) + _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'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Parameters'}) - parameters: typing.List[str] = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) - add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Branch Name'}) - branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Branch Name'}) + 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'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) @attrs.define @@ -1879,32 +1922,6 @@ class JobAzureBackup(Job): '_aapi_repr_': 'Failure Tolerance '}) -@attrs.define -class JobMicrosoftPowerBI(Job): - - _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) - dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - - @attrs.define class JobSnowflake(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 72cc23e..2b00496 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.3.2' +__version__ = '2.3.3' __author__ = 'BMC Software' \ No newline at end of file diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 23b2712..cf24002 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 = ['BOO032022', 'ASM0220223', 'SFI122022', 'ACF082023', 'GCC052024', 'OVM012024', 'ABK042023', 'ADF062021', 'JEN022024', 'MFW022023', 'GDF032022', 'ZSY062022', 'DBT042023', 'GBQ102022', 'GDM082023', 'GFU012023', 'TDM052022', 'AEC082022', 'BAK092023', 'AEM072022', 'COM032023', 'NFI042024', 'SNF092022', 'ZDX112021', 'GDP042022', 'ZLA112022', 'GDR052023', 'ADP122022', 'AQS012023', 'DBX032022', 'RST062023', 'AAR072022', 'ABY122023', 'ZVM062022', 'ATR122022', 'GWF092023', 'GVM062022', 'AHD062022', 'ALM012024', 'ACS042023', 'ADB112022', 'ZBA042022', 'ADO112023', 'MFL022023', 'ZRM082023', 'MBI042022', 'ADY122023', 'ABA092022', 'TER102023', 'ANS032024', 'KBN062023', 'ZFN032022', 'ASF012023', 'TDO042024', 'ICS032022', 'ODI032024', 'ZML022023', 'ODS052024', 'GLU062021', 'ODF0420241', 'UIP072021', 'TAB072023', 'GDQ112023', 'AAT052023', 'QLC092022', 'SOP072023', 'AMM082023', 'GDU102023', 'CMR022024', 'GBA032023', 'ASQ032024'] +IF_PLUGINS = ['ODF0420241', 'ADF062021', 'ZLA112022', 'GCC052024', 'GBQ102022', 'ABK042023', 'ASQ032024', 'UIP072021', 'MFW022023', 'GBA032023', 'GFU012023', 'BOO032022', 'DBT042023', 'BAK092023', 'ZFN032022', 'SFI122022', 'AAT052023', 'COM032023', 'CMR022024', 'ALM012024', 'GDQ112023', 'GDU102023', 'ZBA042022', 'GDR052023', 'ADO112023', 'GDF032022', 'GDP042022', 'ACS042023', 'AEC082022', 'AMM082023', 'TDM052022', 'RST062023', 'ZRM082023', 'AEM072022', 'OVM012024', 'ICS032022', 'SOP072023', 'ASM0220223', 'ABY122023', 'GLU062021', 'ADY122023', 'KBN062023', 'ASF012023', 'ZML022023', 'ZVM062022', 'GWF092023', 'AQS012023', 'TAB072023', 'ODI032024', 'DBX032022', 'GDM082023', 'ATR122022', 'AHD062022', 'ADB112022', 'ANS032024', 'ACF082023', 'AAR072022', 'ODS052024', 'ABA092022', 'QLC092022', 'ZSY062022', 'NFI042024', 'MBI042022', 'MFL022023', 'SNF092022', 'TDO042024', 'KUBERNETE1', 'JEN022024', 'TER102023', 'ADP122022', 'GVM062022', 'ZDX112021'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 17d9301..af39380 100644 --- a/tests/test_sanity.py +++ b/tests/test_sanity.py @@ -2,6 +2,6 @@ def test_version_author(): import ctm_python_client assert ctm_python_client.__author__ == 'BMC Software' - assert ctm_python_client.__version__ == '2.3.2' + assert ctm_python_client.__version__ == '2.3.3'