diff --git a/setup.py b/setup.py index 65c437c..995110f 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ name="ctm-python-client", packages=find_packages(where="src"), package_dir={"": "src"}, - version="2.4.4", + version="2.4.5", 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 27cd180..f638504 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -68,22 +68,6 @@ class ConnectionProfileAwsMainframeModernization(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileGCPDeploymentManager(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Manager URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureDevOps(ConnectionProfile): @@ -102,6 +86,22 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileGCPDeploymentManager(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Manager URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileControlMReports(ConnectionProfile): @@ -285,6 +285,22 @@ class ConnectionProfileAwsBackup(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): @@ -309,22 +325,6 @@ 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 ConnectionProfileAirbyte(ConnectionProfile): @@ -521,6 +521,20 @@ class ConnectionProfileSnowflakeIdP(ConnectionProfile): '_aapi_repr_': 'Scope'}) +@attrs.define +class ConnectionProfileGCPDataprep(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataprep', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataprep'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + gcp_dataprep_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Dataprep URL'}) + user_access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Access Token'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsGlue(ConnectionProfile): @@ -543,20 +557,6 @@ class ConnectionProfileAwsGlue(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileGCPDataprep(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataprep', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataprep'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - gcp_dataprep_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP Dataprep URL'}) - user_access_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Access Token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsGlueDataBrew(ConnectionProfile): @@ -603,6 +603,20 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileDatabricks(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + databricks_workspace_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks workspace url'}) + databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks personal access token'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureBatchAccounts(ConnectionProfile): @@ -663,20 +677,6 @@ class ConnectionProfileAzureFunctions(ConnectionProfile): '_aapi_repr_': 'Custom App Key'}) -@attrs.define -class ConnectionProfileDatabricks(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - databricks_workspace_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks workspace url'}) - databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks personal access token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsEMR(ConnectionProfile): @@ -779,24 +779,6 @@ class ConnectionProfileAzureVM(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) -@attrs.define -class ConnectionProfileApacheNiFi(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'NiFi URL'}) - port: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Port'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsAthena(ConnectionProfile): @@ -835,6 +817,24 @@ class ConnectionProfileDBT(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileApacheNiFi(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'NiFi URL'}) + port: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Port'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -911,7 +911,7 @@ class ConnectionProfileGCPDataproc(ConnectionProfile): '_aapi_repr_': 'Identity Type'}) dataproc_url: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Dataproc URL'}) - service_account_key_json_format: str = attrs.field(kw_only=True, default=None, metadata={ + service_account_key__json_format: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account Key (JSON Format)'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection timeout'}) @@ -1071,32 +1071,6 @@ class ConnectionProfileAzureMachineLearning(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileOCIDataFlow(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Data Flow URL'}) - oci_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'OCI Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User OCID'}) - tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenancy OCID'}) - fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fingerprint'}) - private_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Private Key'}) - config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Config File Path'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureDataFactory(ConnectionProfile): @@ -1126,19 +1100,27 @@ class ConnectionProfileAzureDataFactory(ConnectionProfile): @attrs.define -class ConnectionProfileInformaticaCS(ConnectionProfile): +class ConnectionProfileOCIDataFlow(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Flow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Flow'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Login URL'}) - base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Base URL'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) + oci_data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Data Flow URL'}) + oci_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'OCI Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + user_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User OCID'}) + tenancy_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenancy OCID'}) + fingerprint: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fingerprint'}) + private_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Private Key'}) + config_file_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Config File Path'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1185,6 +1167,24 @@ class WebServiceAuthenticationBasic(AAPIObject): kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationBasic'}) +@attrs.define +class ConnectionProfileInformaticaCS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Login URL'}) + base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Base URL'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileOCIDataScience(ConnectionProfile): @@ -1251,6 +1251,7 @@ class ConnectionProfileAzureDatabricks(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) + @attrs.define class ConnectionProfileTerraform(ConnectionProfile): @@ -1381,6 +1382,26 @@ class ConnectionProfileJenkins(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): @@ -1401,7 +1422,7 @@ class ConnectionProfileAzureBackup(ConnectionProfile): '_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={ + 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'}) @@ -1409,26 +1430,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): @@ -1477,6 +1478,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): @@ -1505,28 +1528,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 ConnectionProfileMicroFocusWindows(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 7ed88b1..8297a4b 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -14,7 +14,7 @@ class JobGCPBatch(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - service_account_email_format: str = attrs.field(kw_only=True, default=None, metadata={ + service_account__email_format: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account (Email Format)'}) project_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Project ID'}) @@ -144,28 +144,6 @@ class JobAwsMainframeModernization(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobGCPDeploymentManager(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Name'}) - yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Yaml Config Content'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureDevOps(Job): @@ -196,6 +174,28 @@ class JobAzureDevOps(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPDeploymentManager(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment Name'}) + yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Yaml Config Content'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobControlMReports(Job): @@ -369,17 +369,17 @@ class JobAwsBackup(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={ @@ -387,17 +387,17 @@ class JobAwsQuickSight(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={ @@ -757,7 +757,7 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Status File Cloud Location Path'}) stoarge_integration_for_location: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Stoarge Integration For Location'}) - statement_timeout_sec: str = attrs.field(kw_only=True, default=None, metadata={ + statement_timeout__sec: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Statement Timeout (Sec)'}) show_more_options: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Show More Options'}) @@ -771,32 +771,12 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Warehouse'}) show_output: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Show Output'}) - polling_interval_sec: str = attrs.field(kw_only=True, default=None, metadata={ + polling_interval__sec: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Polling Interval (Sec)'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsGlue(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Glue', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Glue'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Glue Job Name'}) - glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Glue Job Arguments'}) - arguments: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Arguments'}) - 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 JobGCPDataprep(Job): @@ -819,6 +799,26 @@ class JobGCPDataprep(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAwsGlue(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Glue', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Glue'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Job Name'}) + glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Job Arguments'}) + arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Arguments'}) + 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 JobAwsGlueDataBrew(Job): @@ -869,6 +869,24 @@ class JobAwsCloudFormation(Job): '_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): @@ -931,24 +949,6 @@ class JobAzureFunctions(Job): '_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 JobAwsEMR(Job): @@ -1005,9 +1005,9 @@ class JobGCPComposer(Job): object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ + dag_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={ + dag_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'}) @@ -1067,30 +1067,6 @@ class JobAzureVM(Job): '_aapi_repr_': 'Get Logs'}) -@attrs.define -class JobApacheNiFi(Job): - - _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor Group ID'}) - processor_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Disconnected Node Ack'}) - 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 JobAwsAthena(Job): @@ -1161,6 +1137,30 @@ class JobDBT(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobApacheNiFi(Job): + + _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor Group ID'}) + processor_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Disconnected Node Ack'}) + 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 JobAwsBatch(Job): @@ -1231,7 +1231,7 @@ class JobGCPDataflow(Job): '_aapi_repr_': 'Template Type'}) template_location_gs_: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Template Location (gs://)'}) - parameters_json_format: str = attrs.field(kw_only=True, default=None, metadata={ + parameters__json_format: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters (JSON Format)'}) verification_poll_interval_in_seconds: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Verification Poll Interval (in seconds)'}) @@ -1305,7 +1305,7 @@ class JobGCPDataproc(Job): '_aapi_repr_': 'Request ID'}) workflow_template: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Workflow Template'}) - parameters_json_format: str = attrs.field(kw_only=True, default=None, metadata={ + parameters__json_format: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters (JSON Format)'}) verification_poll_interval_in_seconds: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Verification Poll Interval (in seconds)'}) @@ -1471,24 +1471,6 @@ class JobAzureMachineLearning(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobOCIDataFlow(Job): - - _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Compartment OCID'}) - application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application OCID'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAzureDataFactory(Job): @@ -1512,33 +1494,17 @@ class JobAzureDataFactory(Job): @attrs.define -class JobInformaticaCS(Job): +class JobOCIDataFlow(Job): - _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) + _type: str = attrs.field(init=False, default='Job:OCI Data Flow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Flow'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - task_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Type'}) - use_federation_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Use Federation ID'}) - task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Name'}) - folder_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Path'}) - taskflow_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Taskflow Job Name'}) - task_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'TaskFlow URL'}) - rerun_suspended_taskflow: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Suspended Taskflow'}) - rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun Run ID'}) - input_fields: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Input Fields'}) - call_back_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Call Back URL'}) + compartment_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Compartment OCID'}) + application_ocid: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application OCID'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1603,6 +1569,40 @@ class SoapRequest(AAPIObject): '_aapi_repr_': 'Append Response'}) +@attrs.define +class JobInformaticaCS(Job): + + _type: str = attrs.field(init=False, default='Job:Informatica CS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Informatica CS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + task_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Type'}) + use_federation_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Use Federation ID'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Name'}) + folder_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Folder Path'}) + taskflow_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Taskflow Job Name'}) + task_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'TaskFlow URL'}) + rerun_suspended_taskflow: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Suspended Taskflow'}) + rerun_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Run ID'}) + input_fields: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Fields'}) + call_back_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Call Back URL'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobOCIDataScience(Job): @@ -1661,6 +1661,22 @@ class JobAzureDatabricks(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobApplicationIntegratorAISimplePlugin(JobApplicationIntegrator): + + _type: str = attrs.field(init=False, default='Job:ApplicationIntegrator:AI Simple Plugin', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:ApplicationIntegrator:AI Simple Plugin'}) + 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_user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-User'}) + ai_connection_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Connection Type'}) + + @attrs.define class JobTerraform(Job): @@ -1841,6 +1857,32 @@ class JobJenkins(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): @@ -1879,32 +1921,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): @@ -2009,32 +2025,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): @@ -2061,6 +2051,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 JobMicroFocusWindows(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 5f2e33f..3a7813f 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.4.4' +__version__ = '2.4.5' __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 fd87424..d3c57ce 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 = ['ZFN032022', 'ANS032024', 'OVM012024', 'ASM0220223', 'TAB072023', 'ADY122023', 'ABY122023', 'ODF0420241', 'NFI042024', 'AQS012023', 'SFI122022', 'KBN062023', 'ADO112023', 'ABA092022', 'AMM082023', 'GCC052024', 'AEC082022', 'ASF012023', 'TDM052022', 'BOO032022', 'ICS032022', 'GBQ102022', 'ZSY062022', 'MFW022023', 'GFU012023', 'AAR072022', 'RST062023', 'ALM012024', 'ASQ032024', 'TER102023', 'ZBA042022', 'ZRM082023', 'AHD062022', 'GVM062022', 'CMR022024', 'COM032023', 'GBA032023', 'DBX032022', 'SOP072023', 'SNF092022', 'ADB112022', 'ACF082023', 'ZVM062022', 'GDM082023', 'TDO042024', 'GDU102023', 'JEN022024', 'GLU062021', 'AAT052023', 'UIP072021', 'ATR122022', 'ZML022023', 'ZLA112022', 'GDR052023', 'QLC092022', 'BAK092023', 'ACS042023', 'ABK042023', 'ODI032024', 'MBI042022', 'ADF062021', 'DBT042023', 'ODS052024', 'ADP122022', 'MFL022023', 'ZDX112021', 'GDP042022', 'GDQ112023', 'GWF092023', 'AEM072022', 'GDF032022'] +IF_PLUGINS = ['TAB072023', 'AAR072022', 'GBA032023', 'DBX032022', 'TDM052022', 'ZBA042022', 'ASQ032024', 'ABK042023', 'QLC092022', 'ASF012023', 'ODI032024', 'MFW022023', 'JEN022024', 'AEM072022', 'RST062023', 'MFL022023', 'COM032023', 'AMM082023', 'AQS012023', 'ALM012024', 'UIP072021', 'ZFN032022', 'AHD062022', 'GVM062022', 'OVM012024', 'GWF092023', 'ACS042023', 'ZVM062022', 'ANS032024', 'MBI042022', 'ODF0420241', 'GDU102023', 'ODS052024', 'GCC052024', 'ZRM082023', 'ZML022023', 'ZLA112022', 'GDF032022', 'ASM0220223', 'NFI042024', 'ABY122023', 'ICS032022', 'CMR022024', 'ADB112022', 'TDO042024', 'ZDX112021', 'GBQ102022', 'ADP122022', 'GDR052023', 'GLU062021', 'ZSY062022', 'DBT042023', 'AEC082022', 'TER102023', 'SNF092022', 'ACF082023', 'AAT052023', 'ATR122022', 'KBN062023', 'GDP042022', 'SFI122022', 'ADY122023', 'GDM082023', 'BAK092023', 'BOO032022', 'SOP072023', 'ADF062021', 'GFU012023', 'ADO112023', 'ABA092022', 'GDQ112023'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 0716334..911c3c1 100644 --- a/tests/test_sanity.py +++ b/tests/test_sanity.py @@ -2,6 +2,6 @@ def test_version_author(): import ctm_python_client assert ctm_python_client.__author__ == 'BMC Software' - assert ctm_python_client.__version__ == '2.4.4' + assert ctm_python_client.__version__ == '2.4.5'