diff --git a/setup.py b/setup.py index 83e2b55..b12f7b0 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.2.6", + version="2.3.0", description="Python Workflows for Control-M", long_description=long_description, long_description_content_type='text/markdown', diff --git a/src/aapi/basefolder.py b/src/aapi/basefolder.py index 70cb317..3b07350 100644 --- a/src/aapi/basefolder.py +++ b/src/aapi/basefolder.py @@ -274,6 +274,8 @@ class AdjustEvents(enum.Enum): metadata={'_aapi_repr_': 'When'}) if_list: typing.List[IfBase] = attrs.field( kw_only=True, factory=list, metadata={'_abstract_aapi_container_': True}) + event_list: typing.List[Event] = attrs.field( + kw_only=True, factory=list, metadata={'_abstract_aapi_container_': True}) wait_for_events: typing.List[WaitForEvents] = attrs.field( kw_only=True, factory=list, metadata={'_abstract_aapi_container_': True}) events_to_add: typing.List[AddEvents] = attrs.field( diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py index 2c74850..651a5e9 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -68,6 +68,22 @@ 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): @@ -87,17 +103,23 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): @attrs.define -class ConnectionProfileGCPDeploymentManager(ConnectionProfile): +class ConnectionProfileControlMReports(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:ControlM Reports', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:ControlM Reports'}) 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'}) + control_m_hostname: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Control-M Hostname'}) + control_m_port: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Control-M Port'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Token'}) + 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'}) @@ -203,28 +225,6 @@ class TokenType(enum.Enum): kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationGoogle'}) -@attrs.define -class ConnectionProfileControlMReports(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:ControlM Reports', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:ControlM Reports'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - control_m_hostname: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Control-M Hostname'}) - control_m_port: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Control-M Port'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - api_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Token'}) - 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 ConnectionProfileAwsEC2(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): @@ -427,6 +427,24 @@ class ConnectionProfileAwsSNS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileUIPath(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Name'}) + tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant Url'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + app_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App Secret'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsLambda(ConnectionProfile): @@ -449,24 +467,6 @@ class ConnectionProfileAwsLambda(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileUIPath(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - tenant_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Name'}) - tenant_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant Url'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - app_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App Secret'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAlteryxTrifacta(ConnectionProfile): @@ -521,20 +521,6 @@ class ConnectionProfileAwsSQS(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 ConnectionProfileAwsGlue(ConnectionProfile): @@ -557,6 +543,20 @@ 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,20 +603,6 @@ 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): @@ -647,6 +633,20 @@ class ConnectionProfileAzureBatchAccounts(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 ConnectionProfileAzureFunctions(ConnectionProfile): @@ -735,6 +735,22 @@ class ConnectionProfileGCPDataplex(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileGCPComposer(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + composer_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Composer URL'}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureVM(ConnectionProfile): @@ -764,17 +780,23 @@ class ConnectionProfileAzureVM(ConnectionProfile): @attrs.define -class ConnectionProfileGCPComposer(ConnectionProfile): +class ConnectionProfileAwsAthena(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:AWS Athena', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Athena'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - composer_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Composer URL'}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) + aws_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Base 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_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret Key'}) + 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'}) @@ -795,28 +817,6 @@ class ConnectionProfileDBT(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsAthena(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Athena', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Athena'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Base 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_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret Key'}) - 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 ConnectionProfileApacheNiFi(ConnectionProfile): @@ -901,20 +901,6 @@ class ConnectionProfileGCPBigQuery(ConnectionProfile): '_aapi_repr_': 'Service Account Key'}) -@attrs.define -class ConnectionProfileTalendDataManagement(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Talend Data Management', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Talend Data Management'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) - personal_access_token_authorization: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Personal access token authorization'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - - @attrs.define class ConnectionProfileGCPDataproc(ConnectionProfile): @@ -931,6 +917,20 @@ class ConnectionProfileGCPDataproc(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileTalendDataManagement(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Talend Data Management', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Talend Data Management'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + personal_access_token_authorization: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Personal access token authorization'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + + @attrs.define class ConnectionProfileAzureSynapse(ConnectionProfile): @@ -1071,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): @@ -1477,6 +1477,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 +1527,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 d205847..2b44461 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -144,6 +144,28 @@ 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): @@ -175,21 +197,25 @@ class JobAzureDevOps(Job): @attrs.define -class JobGCPDeploymentManager(Job): +class JobControlMReports(Job): - _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) + _type: str = attrs.field(init=False, default='Job:ControlM Reports', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:ControlM Reports'}) 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'}) + control_m_report_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Control-M Report Name'}) + set_download_file_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Set Download File Name'}) + report_file_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Report File Format'}) + agent_attachments_folder: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Agent Attachments Folder'}) + download_destination_folder: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Download Destination Folder'}) + replace_existing_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Replace Existing File'}) 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={ @@ -222,10 +248,10 @@ class WsRestBody(AAPIObject): '_aapi_repr_': 'URL Request Path'}) ws_rest_body: WsRestBody = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'WsRestBody'}) - url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'URL Parameters'}) - http_headers: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'HTTP Headers'}) + url_parameters: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'URL Parameters'}) + http_headers: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'HTTP Headers'}) output_handling: typing.List[str] = attrs.field( kw_only=True, default=None, metadata={'_aapi_repr_': 'OutputHandling'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ @@ -236,32 +262,6 @@ class WsRestBody(AAPIObject): '_aapi_repr_': 'Append Response'}) -@attrs.define -class JobControlMReports(Job): - - _type: str = attrs.field(init=False, default='Job:ControlM Reports', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:ControlM Reports'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - control_m_report_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Control-M Report Name'}) - set_download_file_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Set Download File Name'}) - report_file_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Report File Format'}) - agent_attachments_folder: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Agent Attachments Folder'}) - download_destination_folder: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Download Destination Folder'}) - replace_existing_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Replace Existing File'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsEC2(Job): @@ -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={ @@ -590,24 +590,6 @@ class JobAwsSNS(Job): push_attribute5_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Value'}) -@attrs.define -class JobAwsLambda(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Lambda', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Lambda'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - function_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Name'}) - function_version: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Function Version'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log to Output'}) - - @attrs.define class JobUIPath(Job): @@ -632,6 +614,24 @@ class JobUIPath(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobAwsLambda(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Lambda', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Lambda'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + function_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Version'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log to Output'}) + + @attrs.define class JobAlteryxTrifacta(Job): @@ -778,21 +778,19 @@ class JobAwsSQS(Job): @attrs.define -class JobGCPDataprep(Job): +class JobAwsGlue(Job): - _type: str = attrs.field(init=False, default='Job:GCP Dataprep', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataprep'}) + _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'}) - flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - execute_job_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Execute Job with Idempotency Token'}) - idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotency Token'}) + 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={ @@ -800,19 +798,21 @@ class JobGCPDataprep(Job): @attrs.define -class JobAwsGlue(Job): +class JobGCPDataprep(Job): - _type: str = attrs.field(init=False, default='Job:AWS Glue', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Glue'}) + _type: str = attrs.field(init=False, default='Job:GCP Dataprep', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataprep'}) 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'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + execute_job_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execute Job with Idempotency Token'}) + 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'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -869,24 +869,6 @@ 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): @@ -927,6 +909,24 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) +@attrs.define +class JobDatabricks(Job): + + _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Databricks Job ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Idempotency Token'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobAzureFunctions(Job): @@ -1023,30 +1023,6 @@ class JobGCPDataplex(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureVM(Job): - - _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - vm_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'VM Name'}) - operation: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Operation'}) - input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Input Parameters'}) - verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Interval'}) - delete_vm_os_disk: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Delete VM OS Disk'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) - - @attrs.define class JobGCPComposer(Job): @@ -1068,25 +1044,27 @@ class JobGCPComposer(Job): @attrs.define -class JobDBT(Job): +class JobAzureVM(Job): - _type: str = attrs.field(init=False, default='Job:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) + _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Job Id'}) - run_comment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run Comment'}) - override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Override Job Commands'}) - define_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Define Commands'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) + vm_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'VM Name'}) + operation: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Operation'}) + input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Parameters'}) + verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Interval'}) + delete_vm_os_disk: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delete VM OS Disk'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) @attrs.define @@ -1137,6 +1115,28 @@ class JobAwsAthena(Job): '_aapi_repr_': 'NoPerm'}) +@attrs.define +class JobDBT(Job): + + _type: str = attrs.field(init=False, default='Job:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Job Id'}) + run_comment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Comment'}) + override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Override Job Commands'}) + define_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Define Commands'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobApacheNiFi(Job): @@ -1285,32 +1285,6 @@ class JobGCPBigQuery(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobTalendDataManagement(Job): - - _type: str = attrs.field(init=False, default='Job:Talend Data Management', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Talend Data Management'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - task_plan_execution: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task/Plan Execution'}) - task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Name'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - log_level: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Log Level'}) - bring_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring logs to output'}) - task_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Polling Intervals'}) - plan_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Plan Name'}) - plan_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Plan Polling Intervals'}) - - @attrs.define class JobGCPDataproc(Job): @@ -1339,6 +1313,32 @@ class JobGCPDataproc(Job): '_aapi_repr_': 'Tolerance'}) +@attrs.define +class JobTalendDataManagement(Job): + + _type: str = attrs.field(init=False, default='Job:Talend Data Management', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Talend Data Management'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + task_plan_execution: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task/Plan Execution'}) + task_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Name'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + log_level: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Log Level'}) + bring_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bring logs to output'}) + task_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Task Polling Intervals'}) + plan_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Plan Name'}) + plan_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Plan Polling Intervals'}) + + @attrs.define class JobAzureSynapse(Job): @@ -1471,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={ @@ -1591,8 +1557,8 @@ class SoapRequest(AAPIObject): '_aapi_repr_': 'SOAP Action'}) soap_request: SoapRequest = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'SoapRequest'}) - http_headers: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'HTTP Headers'}) + http_headers: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'HTTP Headers'}) output_handling: typing.List[str] = attrs.field( kw_only=True, default=None, metadata={'_aapi_repr_': 'OutputHandling'}) connection_timeout: 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): @@ -1829,8 +1829,8 @@ class JobJenkins(Job): '_aapi_repr_': 'Pipeline Name'}) add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Add Parameters'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) + parameters: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Add Branch Name'}) branch_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2009,32 +2009,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 +2035,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 ff9a47b..08030bb 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.2.6' +__version__ = '2.3.0' __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 eec2974..23b2712 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 = ['ZRM082023', 'GDM082023', 'TAB072023', 'ADF062021', 'ADY122023', 'OVM012024', 'GDU102023', 'TDO042024', 'RST062023', 'GDR052023', 'ZDX112021', 'KBN062023', 'GFU012023', 'TDM052022', 'JEN022024', 'MFL022023', 'MFW022023', 'ABK042023', 'MBI042022', 'AMM082023', 'ZVM062022', 'ASM0220223', 'ADB112022', 'AHD062022', 'GDQ112023', 'ATR122022', 'SOP072023', 'COM032023', 'AAR072022', 'ACS042023', 'ABY122023', 'BAK092023', 'ABA092022', 'ZBA042022', 'TER102023', 'AAT052023', 'AEC082022', 'ADP122022', 'GWF092023', 'ANS032024', 'UIP072021', 'GVM062022', 'AEM072022', 'NFI042024', 'GBA032023', 'ODS052024', 'ASQ032024', 'ASF012023', 'QLC092022', 'BOO032022', 'ADO112023', 'SNF092022', 'DBX032022', 'ZSY062022', 'ALM012024', 'DBT042023', 'ODF0420241', 'GBQ102022', 'ODI032024', 'ICS032022', 'GDP042022', 'GCC052024', 'CMR022024', 'ZML022023', 'SFI122022', 'ZLA112022', 'GDF032022', 'ACF082023', 'AQS012023', 'ZFN032022', 'GLU062021'] +IF_PLUGINS = ['BOO032022', 'ASM0220223', 'SFI122022', 'ACF082023', 'GCC052024', 'OVM012024', 'ABK042023', 'ADF062021', 'JEN022024', 'MFW022023', 'GDF032022', 'ZSY062022', 'DBT042023', 'GBQ102022', 'GDM082023', 'GFU012023', 'TDM052022', 'AEC082022', 'BAK092023', 'AEM072022', 'COM032023', 'NFI042024', 'SNF092022', 'ZDX112021', 'GDP042022', 'ZLA112022', 'GDR052023', 'ADP122022', 'AQS012023', 'DBX032022', 'RST062023', 'AAR072022', 'ABY122023', 'ZVM062022', 'ATR122022', 'GWF092023', 'GVM062022', 'AHD062022', 'ALM012024', 'ACS042023', 'ADB112022', 'ZBA042022', 'ADO112023', 'MFL022023', 'ZRM082023', 'MBI042022', 'ADY122023', 'ABA092022', 'TER102023', 'ANS032024', 'KBN062023', 'ZFN032022', 'ASF012023', 'TDO042024', 'ICS032022', 'ODI032024', 'ZML022023', 'ODS052024', 'GLU062021', 'ODF0420241', 'UIP072021', 'TAB072023', 'GDQ112023', 'AAT052023', 'QLC092022', 'SOP072023', 'AMM082023', 'GDU102023', 'CMR022024', 'GBA032023', 'ASQ032024'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 86b24e8..f982410 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.2.6' + assert ctm_python_client.__version__ == '2.3.0'