diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py index b1358ef..0aae41c 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -77,9 +77,9 @@ class ConnectionProfileAwsECS(ConnectionProfile): '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS ECS'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) aws_ecs_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS ECS URL'}) + '_aapi_repr_': 'AWS ECS URL'}) cloud_watch_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cloud Watch URL'}) + '_aapi_repr_': 'Cloud Watch URL'}) aws_region: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'AWS Region'}) authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ @@ -89,7 +89,7 @@ class ConnectionProfileAwsECS(ConnectionProfile): aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'AWS Secret'}) aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS IAM Role'}) + '_aapi_repr_': 'AWS IAM Role'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -255,19 +255,19 @@ class ConnectionProfileAwsStepFunctions(ConnectionProfile): '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Step Functions'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) step_functions_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Step Functions URL'}) + '_aapi_repr_': 'Step Functions URL'}) aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) + '_aapi_repr_': 'AWS Region'}) authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) + '_aapi_repr_': 'Authentication'}) aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) + '_aapi_repr_': 'AWS Access Key'}) aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) + '_aapi_repr_': 'AWS Secret'}) iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) + '_aapi_repr_': 'IAM Role'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -296,34 +296,32 @@ class ConnectionProfileAwsSageMaker(ConnectionProfile): class ConnectionProfileAlteryxTrifacta(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Alteryx Trifacta', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Alteryx Trifacta'}) + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Alteryx Trifacta'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) trifacta_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trifacta URL'}) + '_aapi_repr_': 'Trifacta URL'}) username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) + '_aapi_repr_': 'Username'}) password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) + '_aapi_repr_': 'Password'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define class ConnectionProfileBoomiAtomsphere(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Boomi Atomsphere', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Boomi Atomsphere'}) + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Boomi Atomsphere'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) api_username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Username'}) + '_aapi_repr_': 'API Username'}) api_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Token'}) + '_aapi_repr_': 'API Token'}) end_point: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'End Point'}) + '_aapi_repr_': 'End Point'}) account_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AccountId'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'AccountId'}) @attrs.define @@ -378,14 +376,14 @@ class ConnectionProfileDBT(ConnectionProfile): class ConnectionProfileDatabricks(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Databricks'}) + '_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'}) + '_aapi_repr_': 'Databricks workspace url'}) databricks_personal_access_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks personal access token'}) + '_aapi_repr_': 'Databricks personal access token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -427,7 +425,7 @@ class ConnectionProfileGCPDataFlow(ConnectionProfile): identity_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Identity Type'}) data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DataFlow URL'}) + '_aapi_repr_': 'DataFlow URL'}) service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account Key'}) @@ -506,20 +504,20 @@ class ConnectionProfileInformaticaCS(ConnectionProfile): class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + '_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'}) + '_aapi_repr_': 'Application ID'}) client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) + '_aapi_repr_': 'Client Secret'}) user_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Name'}) + '_aapi_repr_': 'User Name'}) password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) + '_aapi_repr_': 'Password'}) resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) + '_aapi_repr_': 'Resource Group'}) api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) + '_aapi_repr_': 'API URL'}) @attrs.define @@ -566,18 +564,18 @@ class ConnectionProfileMicroFocusWindows(ConnectionProfile): class ConnectionProfileQlikCloud(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Qlik API URL'}) + '_aapi_repr_': 'Qlik API URL'}) tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) + '_aapi_repr_': 'Tenant ID'}) region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) + '_aapi_repr_': 'Region'}) api_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Key'}) + '_aapi_repr_': 'API Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -604,13 +602,14 @@ class ConnectionProfileSnowflake(ConnectionProfile): class ConnectionProfileTalendDataManagement(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Talend Data Management', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Talend Data Management'}) + '_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'}) + '_aapi_repr_': 'API URL'}) personal_access_token_authorization: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Personal access token authorization'}) - + '_aapi_repr_': 'Personal access token authorization'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) @attrs.define class ConnectionProfileUIPath(ConnectionProfile): @@ -857,3 +856,161 @@ class ConnectionProfileGCPDataprep(ConnectionProfile): '_aapi_repr_': 'User Access Token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + + +@attrs.define +class ConnectionProfileGCPFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + gcp_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP API URL'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + +@attrs.define +class ConnectionProfileWebServicesREST(ConnectionProfile): + + @attrs.define + class WebServiceAuthenticationBasic(AAPIObject): + + user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User'}) + use_preemptive_auth: bool = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'UsePreemptiveAuth'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + + @attrs.define + class WebServiceAuthenticationOauth2(AAPIObject): + + @attrs.define + class BasicAuthentication(AAPIObject): + + user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + + @attrs.define + class GrantTypePassword(AAPIObject): + + user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + + basic_authentication: BasicAuthentication = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'BasicAuthentication'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ApiUrl'}) + grant_type_password: GrantTypePassword = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'GrantTypePassword'}) + client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ClientId'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ClientSecret'}) + content_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ContentType'}) + headers: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Headers'}) + body: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Body'}) + + @attrs.define + class WebServiceAuthenticationAws(AAPIObject): + + @attrs.define + class AuthMethodAccessAndSecretKeys(AAPIObject): + + access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AccessKey'}) + secret_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SecretAccessKey'}) + + @attrs.define + class AuthMethodIAMRole(AAPIObject): + + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAMRole'}) + + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + custom_service_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'CustomServiceName'}) + auth_method_access_and_secret_keys: AuthMethodAccessAndSecretKeys = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'AuthMethodAccessAndSecretKeys'}) + auth_method_i_a_m_role: AuthMethodIAMRole = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'AuthMethodIAMRole'}) + + @attrs.define + class WebServiceAuthenticationGoogle(AAPIObject): + + class TokenType(enum.Enum): + + Access = "Access" + Identity = "Identity" + + token_type: TokenType = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'TokenType'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ServiceAccountKey'}) + + _type: str = attrs.field(init=False, default='ConnectionProfile:Web Services REST', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Web Services REST'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + web_service_authentication_basic: WebServiceAuthenticationBasic = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationBasic'}) + web_service_authentication_oauth2: WebServiceAuthenticationOauth2 = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationOauth2'}) + web_service_authentication_aws: WebServiceAuthenticationAws = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationAws'}) + web_service_authentication_google: WebServiceAuthenticationGoogle = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationGoogle'}) + + +@attrs.define +class ConnectionProfileWebServicesSOAP(ConnectionProfile): + + @attrs.define + class WebServiceAuthenticationBasic(AAPIObject): + + user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User'}) + use_preemptive_auth: bool = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'UsePreemptiveAuth'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + + _type: str = attrs.field(init=False, default='ConnectionProfile:Web Services SOAP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Web Services SOAP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + web_service_authentication_basic: WebServiceAuthenticationBasic = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'WebServiceAuthenticationBasic'}) + + +@attrs.define +class ConnectionProfileTableau(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Tableau', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Tableau'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + tableau_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tableau URL'}) + token_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Token Name'}) + token_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Token Secret'}) + site_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Site Name'}) + api_version: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Version'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection timeout'}) + diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index ce266b5..57e9e21 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -307,19 +307,19 @@ class JobAwsStepFunctions(Job): '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) + '_aapi_repr_': 'ConnectionProfile'}) execution_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Execution Name'}) + '_aapi_repr_': 'Execution Name'}) state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'State Machine ARN'}) + '_aapi_repr_': 'State Machine ARN'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) + '_aapi_repr_': 'Parameters'}) show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Execution Logs'}) + '_aapi_repr_': 'Show Execution Logs'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) + '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) + '_aapi_repr_': 'Failure Tolerance'}) @attrs.define @@ -355,37 +355,37 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alteryx Trifacta'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) + '_aapi_repr_': 'ConnectionProfile'}) flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) + '_aapi_repr_': 'Flow Name'}) rerun_with_new_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Rerun With New Idempotency Token'}) + '_aapi_repr_': 'Rerun With New Idempotency Token'}) idempotent_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotent Token'}) + '_aapi_repr_': 'Idempotent Token'}) retrack_job_status: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retrack Job Status'}) + '_aapi_repr_': 'Retrack Job Status'}) run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run-ID'}) + '_aapi_repr_': 'Run-ID'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) + '_aapi_repr_': 'Status Polling Frequency'}) @attrs.define class JobBoomiAtomsphere(Job): _type: str = attrs.field(init=False, default='Job:Boomi Atomsphere', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Boomi Atomsphere'}) + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Boomi Atomsphere'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) + '_aapi_repr_': 'ConnectionProfile'}) process_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Process Name'}) + '_aapi_repr_': 'Process Name'}) atom_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Atom Name'}) + '_aapi_repr_': 'Atom Name'}) polling_interval_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Polling Interval Frequency'}) + '_aapi_repr_': 'Polling Interval Frequency'}) tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) + '_aapi_repr_': 'Tolerance'}) @attrs.define @@ -438,18 +438,18 @@ class JobDBT(Job): class JobDatabricks(Job): _type: str = attrs.field(init=False, default='Job:Databricks', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Databricks'}) + '_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'}) + '_aapi_repr_': 'ConnectionProfile'}) databricks_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Databricks Job ID'}) + '_aapi_repr_': 'Databricks Job ID'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) + '_aapi_repr_': 'Parameters'}) idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Idempotency Token'}) + '_aapi_repr_': 'Idempotency Token'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) + '_aapi_repr_': 'Status Polling Frequency'}) @attrs.define @@ -688,26 +688,26 @@ class JobInformaticaCS(Job): class JobMicrosoftPowerBI(Job): _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + '_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'}) + '_aapi_repr_': 'ConnectionProfile'}) dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) + '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) + '_aapi_repr_': 'Workspace Name'}) workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) + '_aapi_repr_': 'Workspace ID'}) dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) + '_aapi_repr_': 'Dataset ID'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) + '_aapi_repr_': 'Parameters'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection Timeout'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) + '_aapi_repr_': 'Status Polling Frequency'}) pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) + '_aapi_repr_': 'Pipeline ID'}) @attrs.define @@ -798,20 +798,20 @@ class JobMicroFocusWindows(Job): class JobQlikCloud(Job): _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) + '_aapi_repr_': 'ConnectionProfile'}) reload_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reload Type'}) + '_aapi_repr_': 'Reload Type'}) app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) + '_aapi_repr_': 'App ID'}) print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Print Log to Output'}) + '_aapi_repr_': 'Print Log to Output'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) + '_aapi_repr_': 'Status Polling Frequency'}) tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) + '_aapi_repr_': 'Tolerance'}) @attrs.define @@ -902,26 +902,26 @@ class JobSnowflake(Job): class JobTalendDataManagement(Job): _type: str = attrs.field(init=False, default='Job:Talend Data Management', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Talend Data Management'}) + '_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'}) + '_aapi_repr_': 'ConnectionProfile'}) task_plan_execution: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task/Plan Execution'}) + '_aapi_repr_': 'Task/Plan Execution'}) task_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Name'}) + '_aapi_repr_': 'Task Name'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) + '_aapi_repr_': 'Parameters'}) log_level: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Log Level'}) + '_aapi_repr_': 'Log Level'}) bring_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring logs to output'}) + '_aapi_repr_': 'Bring logs to output'}) task_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Polling Intervals'}) + '_aapi_repr_': 'Task Polling Intervals'}) plan_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Plan Name'}) + '_aapi_repr_': 'Plan Name'}) plan_polling_intervals: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Plan Polling Intervals'}) + '_aapi_repr_': 'Plan Polling Intervals'}) @attrs.define @@ -1184,3 +1184,102 @@ class JobGCPDataprep(Job): '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Failure Tolerance'}) + + +@attrs.define +class JobGCPFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Functions'}) + 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'}) + location: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Location'}) + function_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Name'}) + function_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Function Parameters'}) + url_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'URL Parameters'}) + body: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Body'}) + 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'}) + get_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Logs'}) + + +@attrs.define +class JobWebServicesREST(Job): + + _type: str = attrs.field(init=False, default='Job:Web Services REST', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Web Services REST'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Method'}) + url_request_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'URL Request Path'}) + 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'}) + 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={ + '_aapi_repr_': 'Connection Timeout'}) + append_request: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Request'}) + append_response: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Response'}) + + +@attrs.define +class JobWebServicesSOAP(Job): + + _type: str = attrs.field(init=False, default='Job:Web Services SOAP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Web Services SOAP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + soap_action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'SOAP Action'}) + http_headers: 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={ + '_aapi_repr_': 'Connection Timeout'}) + append_request: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Request'}) + append_response: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Response'}) + + +@attrs.define +class JobTableau(Job): + + _type: str = attrs.field(init=False, default='Job:Tableau', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Tableau'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + datasource_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datasource Name'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index a37c1ce..152d08e 100644 --- a/src/ctm_python_client/ext/autogen.py +++ b/src/ctm_python_client/ext/autogen.py @@ -9,47 +9,59 @@ __all__ = ['generate_ai_plugins_classes'] IF_PLUGINS = [ - 'ABA092022', 'GBA032023', + 'AMM082023', + 'GDM082023', + 'RST062023', + 'AEC082022', + 'BAK092023', + 'AHD062022', + 'AQS012023', + 'GVM062022', + 'ASM0220223', + 'GDU102023', + 'UIP072021', + 'ATR122022', + 'SFI122022', + 'GDR052023', + 'GLU062021', + 'ADB112022', + 'ACF082023', + 'ZBA042022', + 'ZFN032022', + 'DBX032022', + 'AEM072022', + 'TAB072023', + 'ZVM062022', + 'AAT052023', + 'DBT042023', + 'ABA092022', + 'GWF092023', 'GDF032022', 'GBQ102022', - 'AEC082022', - 'TDM052022', 'GDP042022', + 'TDM052022', 'ZSY062022', - 'AQS012023', - 'AHD062022', 'MFL022023', 'COM032023', 'ZML022023', - 'GVM062022', 'ADF062021', 'ASF012023', - 'ASM0220223', 'ICS032022', + 'SOP072023', 'BOO032022', 'ZDX112021', + 'TER102023', 'ACS042023', 'AAR072022', - 'UIP072021', + 'GFU012023', 'ZLA112022', - 'ATR122022', 'QLC092022', - 'GLU062021', - 'GDR052023', - 'ADB112022', - 'MBI042022', 'ABK042023', + 'MBI042022', 'SNF092022', 'ADP122022', - 'ZBA042022', - 'DBX032022', - 'ZFN032022', - 'AEM072022', - 'MFW022023', - 'ZVM062022', - 'DBT042023', - 'AAT052023' + 'MFW022023' ]