From 0f48ca54ba6976d2c1082d4efc16337e350e92dd Mon Sep 17 00:00:00 2001 From: dancohen Date: Sun, 17 Aug 2025 12:35:15 +0300 Subject: [PATCH] Control-M Integrations Factory up to August 2025 --- setup.py | 2 +- .../connection_profiles.py | 319 +++++++------ src/aapi/integration_factory/jobs.py | 421 +++++++++++------- src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/ext/autogen.py | 2 +- tests/test_sanity.py | 2 +- 6 files changed, 451 insertions(+), 297 deletions(-) diff --git a/setup.py b/setup.py index cbff98e..4e34aa6 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ name="ctm-python-client", packages=find_packages(where="src"), package_dir={"": "src"}, - version="2.5.3", + version="2.5.4", 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 12ddd4e..99de7a2 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -32,6 +32,34 @@ class ConnectionProfileAwsDataSync(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPVertexAI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Vertex AI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Vertex AI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identitty_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identitty Type'}) + type_of_service: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Type of Service'}) + gcp_vertex_ai__url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Vertex AI URL'}) + gcp_vertex_ai_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Vertex AI URL'}) + location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Location'}) + service_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service 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 ConnectionProfileAwsDynamoDB(ConnectionProfile): @@ -438,6 +466,8 @@ class ConnectionProfileAzureFunctions(ConnectionProfile): '_aapi_repr_': 'Azure Login url'}) function_app_web_site: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Function App Web Site'}) + resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource'}) custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Custom App Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ @@ -487,35 +517,35 @@ class ConnectionProfileTableau(ConnectionProfile): @attrs.define -class ConnectionProfileGCPComposer(ConnectionProfile): +class ConnectionProfileGCPDataplex(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - composer_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Composer URL'}) identity_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Identity Type'}) + gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Dataplex URL'}) service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection timeout'}) @attrs.define -class ConnectionProfileGCPDataplex(ConnectionProfile): +class ConnectionProfileGCPComposer(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) + composer_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Composer URL'}) identity_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Identity Type'}) - gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP Dataplex URL'}) service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection timeout'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -594,6 +624,26 @@ class ConnectionProfileSAPBTPScheduler(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPEventArc(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP EventArc', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP EventArc'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + eventarc_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Eventarc URL'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + 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 ConnectionProfileGCPDataflow(ConnectionProfile): @@ -1066,26 +1116,6 @@ class ConnectionProfileVeeamBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - user_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Name'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) - - @attrs.define class ConnectionProfileAzureBackup(ConnectionProfile): @@ -1114,6 +1144,26 @@ class ConnectionProfileAzureBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Name'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + + @attrs.define class ConnectionProfileSnowflake(ConnectionProfile): @@ -1166,6 +1216,32 @@ class ConnectionProfileMicrosoftPowerBISP(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicroFocusWindows(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Micro Focus Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Micro Focus Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + mfbsi_directory_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MFBSI Directory Path'}) + mfbsi_config_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'MFBSI Config Path'}) + runtime_environment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Runtime Environment'}) + additional_micro_focus_settings_script: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Additional Micro Focus Settings Script'}) + micro_focus_authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Micro Focus Authentication'}) + micro_focus_user_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Micro Focus User ID'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + run_as: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run As'}) + run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RunAs-Pass'}) + + @attrs.define class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): @@ -1192,26 +1268,6 @@ class ConnectionProfileAwsDatabaseMigrationService(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileMicroFocusWindows(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Micro Focus Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Micro Focus Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - mfbsi_directory_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'MFBSI Directory Path'}) - mfbsi_config_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'MFBSI Config Path'}) - runtime_environment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Runtime Environment'}) - additional_micro_focus_settings_script: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Additional Micro Focus Settings Script'}) - run_as: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run As'}) - run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'RunAs-Pass'}) - - @attrs.define class ConnectionProfileIBMDataStageLinux(ConnectionProfile): @@ -1433,22 +1489,6 @@ class ConnectionProfileTalendOAuth(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureHDInsight(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Name'}) - cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Username'}) - cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsQuickSight(ConnectionProfile): @@ -1473,6 +1513,22 @@ class ConnectionProfileAwsQuickSight(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureHDInsight(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Name'}) + cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Username'}) + cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileCircleCI(ConnectionProfile): @@ -1742,30 +1798,6 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileIBMDataStageWindows(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - server_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Server Name'}) - domain_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Domain Name'}) - 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'}) - authentication_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication File'}) - empty: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty'}) - d_s_j_o_b_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DSJOB Path'}) - - @attrs.define class ConnectionProfileAwsSQS(ConnectionProfile): @@ -1792,6 +1824,30 @@ class ConnectionProfileAwsSQS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileIBMDataStageWindows(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + server_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Server Name'}) + domain_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Domain Name'}) + 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'}) + authentication_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication File'}) + empty: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty'}) + d_s_j_o_b_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DSJOB Path'}) + + @attrs.define class ConnectionProfileSnowflakeIdP(ConnectionProfile): @@ -1870,6 +1926,12 @@ class ConnectionProfileDatabricks(ConnectionProfile): 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'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + 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'}) 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={ @@ -1920,6 +1982,20 @@ class ConnectionProfileDBT(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): @@ -1948,20 +2024,6 @@ class ConnectionProfileAzureServiceBus(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileFivetran(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fivetran Base URL'}) - api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Base 64 Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -2180,6 +2242,7 @@ class ConnectionProfileInformaticaCS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) + @attrs.define class ConnectionProfileTerraform(ConnectionProfile): @@ -2290,6 +2353,28 @@ class ConnectionProfileOCIVM(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsDataPipeline(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Pipeline URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileOCIDataIntegration(ConnectionProfile): @@ -2318,28 +2403,6 @@ class ConnectionProfileOCIDataIntegration(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsDataPipeline(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Pipeline URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileGCPCloudRun(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 31cf295..caaf40f 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -30,6 +30,40 @@ class JobAwsDataSync(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPVertexAI(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Vertex AI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Vertex AI'}) + 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_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Name'}) + instance_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Instance Name'}) + pipeline_run_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Run Name'}) + zone: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Zone'}) + service_account: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account'}) + pipeline_specification: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Specification'}) + gcs_output_directory: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCS Output Directory'}) + add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Parameters'}) + pipeline_runtime_paramaters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Runtime Paramaters'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + empty: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'EMPTY'}) + + @attrs.define class JobAwsDynamoDB(Job): @@ -626,30 +660,6 @@ class JobTableau(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobGCPComposer(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Composer'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Name'}) - d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Run ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Only Failed Tasks'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobGCPDataplex(Job): @@ -676,6 +686,32 @@ class JobGCPDataplex(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPComposer(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Composer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + last_d_a_g: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Last DAG'}) + d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Name'}) + d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Run ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Only Failed Tasks'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAzureVM(Job): @@ -762,6 +798,52 @@ class JobSAPBTPScheduler(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPEventArc(Job): + + _type: str = attrs.field(init=False, default='Job:GCP EventArc', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP EventArc'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + operation: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Operation'}) + trigger_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Name'}) + service_account__email_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account (Email Format)'}) + event_filters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Event Filters'}) + destination: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Destination'}) + service: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + path: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Path'}) + destination_uri: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Destination URI'}) + network_attachment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Network Attachment'}) + cluster: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster'}) + location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Location'}) + namespace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Namespace'}) + workflow: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + use_advanced_json_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Use Advanced JSON Format'}) + json_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'JSON Format'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobGCPDataflow(Job): @@ -1340,32 +1422,6 @@ class JobVeeamBackup(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobMicrosoftPowerBI(Job): - - _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) - dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - - @attrs.define class JobAzureBackup(Job): @@ -1404,6 +1460,32 @@ class JobAzureBackup(Job): '_aapi_repr_': 'Failure Tolerance '}) +@attrs.define +class JobMicrosoftPowerBI(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) + workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace Name'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + + @attrs.define class JobSnowflake(Job): @@ -1524,30 +1606,6 @@ class JobMicrosoftPowerBISP(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsDatabaseMigrationService(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Database Migration Service', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Database Migration Service'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - data_migration_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Migration ARN'}) - start_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Start Type'}) - database_migration_task_arn: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Database Migration Task ARN'}) - output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Output Job Logs'}) - failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance '}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobMicroFocusWindows(Job): @@ -1590,6 +1648,30 @@ class JobMicroFocusWindows(Job): kw_only=True, default=None, metadata={'_aapi_repr_': 'Modified JCL Path and Filename'}) +@attrs.define +class JobAwsDatabaseMigrationService(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Database Migration Service', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Database Migration Service'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + data_migration_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Migration ARN'}) + start_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Start Type'}) + database_migration_task_arn: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Database Migration Task ARN'}) + output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output Job Logs'}) + failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance '}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobIBMDataStageLinux(Job): @@ -1871,17 +1953,17 @@ class JobTalendOAuth(Job): @attrs.define -class JobAzureHDInsight(Job): +class JobAwsQuickSight(Job): - _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) + _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring job logs to output'}) + aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Dataset ID'}) + refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Refresh Type'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1889,17 +1971,17 @@ class JobAzureHDInsight(Job): @attrs.define -class JobAwsQuickSight(Job): +class JobAzureHDInsight(Job): - _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) + _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Dataset ID'}) - refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Refresh Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bring job logs to output'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2152,40 +2234,6 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) - - @attrs.define class JobAwsSQS(Job): @@ -2223,6 +2271,40 @@ class JobAwsSQS(Job): attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) +@attrs.define +class JobIBMDataStageWindows(Job): + + _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project'}) + datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datastage Job'}) + job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Invocation ID (Optional)'}) + parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameter File'}) + stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Stop Stages After Number Of Rows'}) + abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Abort Job After Number Of Warnings'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log To Output'}) + run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run In Restart Mode'}) + reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reset Job Before Run'}) + empty1: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty1'}) + + @attrs.define class JobSnowflakeIdP(Job): @@ -2359,8 +2441,14 @@ class JobDatabricks(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) + databricks_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks Job Name'}) databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Databricks Job ID'}) + databricks_job_id_o_auth_o_id_c: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Databricks Job ID OAuth OIDC'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2443,23 +2531,6 @@ class JobDBT(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): @@ -2484,6 +2555,23 @@ class JobFivetran(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAzureServiceBus(Job): + + _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Bus Namespace'}) + queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) + message_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Format'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) + + @attrs.define class JobAwsBatch(Job): @@ -2804,6 +2892,8 @@ class JobInformaticaCS(Job): '_aapi_repr_': 'Rerun Suspended Taskflow'}) rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Rerun Run ID'}) + process_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Process Name'}) 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={ @@ -2814,6 +2904,7 @@ class JobInformaticaCS(Job): '_aapi_repr_': 'Failure Tolerance'}) + @attrs.define class JobTerraform(Job): @@ -2930,32 +3021,6 @@ class JobOCIVM(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobOCIDataIntegration(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - actions: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Actions'}) - workspace_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace OCID'}) - application_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application Key'}) - task_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Key'}) - task_run_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Run Name'}) - task_run_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Run Input Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsDataPipeline(Job): @@ -2982,6 +3047,32 @@ class JobAwsDataPipeline(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobOCIDataIntegration(Job): + + _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + actions: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Actions'}) + workspace_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace OCID'}) + application_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application Key'}) + task_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Key'}) + task_run_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Run Name'}) + task_run_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Run Input Parameters'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobGCPCloudRun(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index a146de6..25cf6b9 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.5.3' +__version__ = '2.5.4' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 05dcbd9..166cb3e 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 = ['AAR072022', 'KBN062023', 'GCR042024', 'ABY122023', 'ABA092022', 'GCC052024', 'PDY092024', 'CMR022024', 'DBX032022', 'GBQ102022', 'RBK072025', 'AHD062022', 'SOP072023', 'GDM082023', 'ZFN032022', 'DTG052025', 'ATR122022', 'CCI012025', 'GDF032022', 'ADO112023', 'DBT042023', 'RST062023', 'ODI032024', 'TER102023', 'GDP042022', 'ZRM082023', 'AAT052023', 'PBI082024', 'MFL022023', 'GWF092023', 'AEM072022', 'ODF0420241', 'ADF062021', 'ASB012025', 'ODS052024', 'VNB032025', 'ASQ032024', 'ZDX112021', 'ASM0220223', 'GFU012023', 'QLC092022', 'ADB112022', 'TAB072023', 'DSW122024', 'GDQ112023', 'COM032023', 'AQS012023', 'AAP092024', 'SNF092022', 'MFW022023', 'NBU032025', 'AWX122024', 'BAK092023', 'NFI042024', 'AAF112024', 'ZWB072025', 'VBR062025', 'GBA032023', 'RMQ082024', 'DTG022025', 'ZSY062022', 'ANS032024', 'GLU062021', 'UIP072021', 'ARS112024', 'FVT032025', 'GDU102023', 'ADS102024', 'TDO042024', 'MBI042022', 'JEN022024', 'APP022025', 'ASF012023', 'SFI122022', 'BOO032022', 'GDR052023', 'ACF082023', 'ICS032022', 'TDM052022', 'ZLA112022', 'VMW102024', 'DSL122024', 'SBT032025', 'ADM062025', 'ZML022023', 'GVM062022', 'ZVM062022', 'ABK042023', 'ACS042023', 'ADY122023', 'ZBA042022', 'ADP122022', 'OVM012024', 'AMW112024', 'AST072024', 'ALM012024', 'BEC032025', 'AEC082022', 'AMM082023'] +IF_PLUGINS = ['ZDX112021', 'RST062023', 'AMW112024', 'ADP122022', 'TAB072023', 'AHD062022', 'ABK042023', 'DSL122024', 'ZVM062022', 'BEC032025', 'ZWB072025', 'AMM082023', 'GLU062021', 'TDO042024', 'ALM012024', 'PDY092024', 'GDP042022', 'ZFN032022', 'AWX122024', 'GVA092025', 'ACS042023', 'SBT032025', 'MFL022023', 'TER102023', 'ADB112022', 'MBI042022', 'ADF062021', 'GWF092023', 'ASQ032024', 'AAR072022', 'UIP072021', 'ZRM082023', 'SNF092022', 'ZLA112022', 'AQS012023', 'ATR122022', 'PBI082024', 'GFU012023', 'TDM052022', 'ABY122023', 'ARS112024', 'NFI042024', 'ASM0220223', 'OVM012024', 'SOP072023', 'DTG052025', 'VBR062025', 'GDF032022', 'GEA072025', 'ICS032022', 'RBK072025', 'ADY122023', 'BAK092023', 'ZBA042022', 'QLC092022', 'CMR022024', 'APP022025', 'GDU102023', 'VNB032025', 'ODI032024', 'AAF112024', 'ZSY062022', 'SFI122022', 'CCI012025', 'ADS102024', 'DBT042023', 'RMQ082024', 'ANS032024', 'ACF082023', 'AEC082022', 'GBA032023', 'DSW122024', 'MFW022023', 'BOO032022', 'DBX032022', 'GDR052023', 'DTG022025', 'AST072024', 'NBU032025', 'GVM062022', 'JEN022024', 'ADO112023', 'AAT052023', 'ABA092022', 'AEM072022', 'GCC052024', 'ASF012023', 'VMW102024', 'GBQ102022', 'GDM082023', 'KBN062023', 'FVT032025', 'ODF0420241', 'GDQ112023', 'GCR042024', 'AAP092024', 'ADM062025', 'ZML022023', 'ODS052024', 'ASB012025', 'COM032023'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 164f3e5..6746012 100644 --- a/tests/test_sanity.py +++ b/tests/test_sanity.py @@ -2,6 +2,6 @@ def test_version_author(): import ctm_python_client assert ctm_python_client.__author__ == 'BMC Software' - assert ctm_python_client.__version__ == '2.5.3' + assert ctm_python_client.__version__ == '2.5.4'