diff --git a/setup.py b/setup.py index 9ce908c..735d6b8 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ name="ctm-python-client", packages=find_packages(where="src"), package_dir={"": "src"}, - version="2.4.8", + version="2.4.9", description="Python Workflows for Control-M", long_description=long_description, long_description_content_type='text/markdown', diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py index 1e1cb10..0d50d56 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -30,6 +30,24 @@ class ConnectionProfileIBMDataStageLinux(ConnectionProfile): '_aapi_repr_': 'DSJOB Path'}) +@attrs.define +class ConnectionProfileAlibabaECS(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Alibaba ECS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Alibaba ECS'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + access_key_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Access Key ID'}) + secret_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Secret Access Key'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + api_v_e_r_s_i_o_n: 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'}) + + @attrs.define class ConnectionProfileAwsDataSync(ConnectionProfile): @@ -634,8 +652,18 @@ class ConnectionProfileAwsLambda(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) iam_role: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) @attrs.define @@ -672,6 +700,28 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileSnowflakeIdP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Endpoint URL'}) + account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Identifier'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + idp_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IDP URL'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + + @attrs.define class ConnectionProfileIBMDataStageWindows(ConnectionProfile): @@ -696,28 +746,6 @@ class ConnectionProfileIBMDataStageWindows(ConnectionProfile): '_aapi_repr_': 'DSJOB Path'}) -@attrs.define -class ConnectionProfileSnowflakeIdP(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake IdP', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake IdP'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - endpoint_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Endpoint URL'}) - account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account Identifier'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - idp_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IDP URL'}) - scope: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Scope'}) - - @attrs.define class ConnectionProfileAwsSQS(ConnectionProfile): @@ -838,32 +866,6 @@ class ConnectionProfileAwsCloudFormation(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsAppFlow(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS AppFlow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS AppFlow'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_appflow_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Appflow 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_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access key ID'}) - 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'}) - assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role ARN'}) - assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Assume Role Session'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileDatabricks(ConnectionProfile): @@ -876,6 +878,12 @@ class ConnectionProfileDatabricks(ConnectionProfile): '_aapi_repr_': 'Databricks personal access token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) @attrs.define @@ -908,6 +916,32 @@ class ConnectionProfileAzureBatchAccounts(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsAppFlow(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS AppFlow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS AppFlow'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_appflow_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Appflow 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_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access key ID'}) + 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'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureFunctions(ConnectionProfile): @@ -982,6 +1016,22 @@ class ConnectionProfileTableau(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 ConnectionProfileGCPDataplex(ConnectionProfile): @@ -1027,35 +1077,17 @@ class ConnectionProfileAzureVM(ConnectionProfile): @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 ConnectionProfileApacheNiFi(ConnectionProfile): +class ConnectionProfileDBT(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'NiFi URL'}) - port: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Port'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) + dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT URL'}) + dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Token'}) + account_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account ID'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1083,17 +1115,33 @@ class ConnectionProfileAwsAthena(ConnectionProfile): @attrs.define -class ConnectionProfileDBT(ConnectionProfile): +class ConnectionProfileApacheNiFi(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:DBT'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - dbt_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT URL'}) - dbt_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Token'}) - account_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account ID'}) + ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'NiFi URL'}) + port: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Port'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + +@attrs.define +class ConnectionProfileFivetran(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fivetran Base URL'}) + api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Base 64 Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1144,6 +1192,10 @@ class ConnectionProfileAwsBatch(ConnectionProfile): '_aapi_repr_': 'AWS Secret'}) iam_role: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'IAM Role'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1352,6 +1404,30 @@ class ConnectionProfileVMwareByBroadcom(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileDatadog(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Datadog', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Datadog'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + datadog_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datadog URL'}) + site: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Site'}) + api_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key'}) + application_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + + @attrs.define class ConnectionProfileMicroFocusLinux(ConnectionProfile): @@ -1524,6 +1600,28 @@ class ConnectionProfileAzureDataFactory(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileAwsStepFunctions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Step Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Step Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + step_functions_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Step Functions URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileWebServicesSOAP(ConnectionProfile): @@ -1562,28 +1660,6 @@ class ConnectionProfileInformaticaCS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsStepFunctions(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Step Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Step Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - step_functions_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Step Functions URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileOCIDataScience(ConnectionProfile): @@ -1656,6 +1732,12 @@ class ConnectionProfileAzureDatabricks(ConnectionProfile): '_aapi_repr_': 'Databricks Resource'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) @attrs.define @@ -1756,17 +1838,19 @@ class ConnectionProfileAzureLogicApps(ConnectionProfile): @attrs.define -class ConnectionProfileJenkins(ConnectionProfile): +class ConnectionProfileQlikCloud(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Jenkins'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - jenkins_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Jenkins URL'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - user_api_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User API Token'}) + qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Qlik API URL'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Region'}) + api_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1790,19 +1874,17 @@ class ConnectionProfileRabbitMQ(ConnectionProfile): @attrs.define -class ConnectionProfileQlikCloud(ConnectionProfile): +class ConnectionProfileJenkins(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Qlik Cloud'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Jenkins'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - qlik_api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Qlik API URL'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Region'}) - api_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Key'}) + jenkins_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Jenkins URL'}) + username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Username'}) + user_api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User API Token'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -1951,6 +2033,28 @@ class ConnectionProfileMicrosoftPowerBISP(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): @@ -1979,28 +2083,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 890a0ab..c3d5515 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -40,6 +40,28 @@ class JobIBMDataStageLinux(Job): '_aapi_repr_': 'Empty1'}) +@attrs.define +class JobAlibabaECS(Job): + + _type: str = attrs.field(init=False, default='Job:Alibaba ECS', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Alibaba ECS'}) + 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'}) + instance_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Instance ID'}) + tag_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Name'}) + tag_value: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Value'}) + verification_poll_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Interval'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsDataSync(Job): @@ -518,6 +540,10 @@ class JobGCPVM(Job): metadata={'_aapi_repr_': 'Zone'}) operation: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Operation'}) + tag_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Name'}) + tag_value: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Value'}) template_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Template Name'}) instance_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -824,40 +850,6 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Status Polling Frequency'}) -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) - - @attrs.define class JobSnowflakeIdP(Job): @@ -946,6 +938,40 @@ class JobSnowflakeIdP(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobIBMDataStageWindows(Job): + + _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project'}) + datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datastage Job'}) + job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Invocation ID (Optional)'}) + parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameter File'}) + stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Stop Stages After Number Of Rows'}) + abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Abort Job After Number Of Warnings'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log To Output'}) + run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run In Restart Mode'}) + reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reset Job Before Run'}) + empty1: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty1'}) + + @attrs.define class JobAwsSQS(Job): @@ -1099,32 +1125,6 @@ class JobAwsCloudFormation(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsAppFlow(Job): - - _type: str = attrs.field(init=False, default='Job:AWS AppFlow', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS AppFlow'}) - 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'}) - flow_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name'}) - flow_name__iam: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name - IAM'}) - flow_name__assume_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Flow Name - Assume Role'}) - trigger_flow_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trigger Flow with Idempotency Token'}) - client_token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client 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={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobDatabricks(Job): @@ -1139,6 +1139,8 @@ class JobDatabricks(Job): '_aapi_repr_': 'Parameters'}) idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Idempotency Token'}) + show_tasks_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Tasks 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={ @@ -1185,6 +1187,32 @@ class JobAzureBatchAccounts(Job): '_aapi_repr_': 'Content-Type'}) +@attrs.define +class JobAwsAppFlow(Job): + + _type: str = attrs.field(init=False, default='Job:AWS AppFlow', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS AppFlow'}) + 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'}) + flow_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name'}) + flow_name__iam: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name - IAM'}) + flow_name__assume_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Name - Assume Role'}) + trigger_flow_with_idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Flow with Idempotency Token'}) + client_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client 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={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAzureFunctions(Job): @@ -1261,6 +1289,30 @@ class JobTableau(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGCPComposer(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Composer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Name'}) + d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DAG Run ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Only Failed Tasks'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobGCPDataplex(Job): @@ -1299,6 +1351,10 @@ class JobAzureVM(Job): '_aapi_repr_': 'VM Name'}) operation: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Operation'}) + tag_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Name'}) + tag_value: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tag Value'}) 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={ @@ -1307,52 +1363,28 @@ class JobAzureVM(Job): '_aapi_repr_': 'Delete VM OS Disk'}) tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) get_logs: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Get Logs'}) @attrs.define -class JobGCPComposer(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Composer'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Name'}) - d_a_g_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Run ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - only_failed_tasks: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Only Failed Tasks'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - -@attrs.define -class JobApacheNiFi(Job): +class JobDBT(Job): - _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) + _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'}) - processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor Group ID'}) - processor_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Disconnected Node Ack'}) - parameters_: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters '}) + 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={ @@ -1408,21 +1440,47 @@ class JobAwsAthena(Job): @attrs.define -class JobDBT(Job): +class JobApacheNiFi(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:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - 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'}) + processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor Group ID'}) + processor_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Disconnected Node Ack'}) + parameters_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters '}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + +@attrs.define +class JobFivetran(Job): + + _type: str = attrs.field(init=False, default='Job:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + job_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Type'}) + connection_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection ID'}) + connection_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Name'}) + force_incremental_sync: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Force Incremental Sync'}) + transformation_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Transformation ID'}) 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={ @@ -1582,8 +1640,12 @@ class JobGCPBigQuery(Job): '_aapi_repr_': 'Run Select Query and Copy to Table'}) table_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Table Name'}) + query_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Query Type'}) sql_statement: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'SQL Statement'}) + load_query_from_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Load Query From File'}) query_parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Query Parameters'}) routine: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1648,12 +1710,14 @@ class JobVeritasNetBackup(Job): '_aapi_repr_': 'Action'}) json_parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'JSON Parameters'}) + create_jobs_per_client: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Create Jobs Per Client'}) policy_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Policy Name'}) - schedule_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Schedule Name'}) client_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Client Name'}) + schedule_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Schedule Name'}) keyword: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Keyword'}) instance_name: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1846,6 +1910,36 @@ class JobVMwareByBroadcom(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobDatadog(Job): + + _type: str = attrs.field(init=False, default='Job:Datadog', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Datadog'}) + 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'}) + workflow_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow ID'}) + workflow_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow Parameters'}) + synthetics_test_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Synthetics Test Type'}) + test_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Test Parameters'}) + event_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Event Parameters'}) + incident_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Incident Parameters'}) + delay_logs_retrieval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delay Logs Retrieval'}) + 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 JobMicroFocusLinux(Job): @@ -2006,6 +2100,28 @@ class JobAzureDataFactory(Job): '_aapi_repr_': 'Reference Pipeline Run ID'}) +@attrs.define +class JobAwsStepFunctions(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + execution_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execution Name'}) + state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'State Machine ARN'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Execution Logs'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobWebServicesSOAP(Job): @@ -2076,28 +2192,6 @@ class JobInformaticaCS(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsStepFunctions(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Step Functions', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Step Functions'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - execution_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Execution Name'}) - state_machine_arn: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'State Machine ARN'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - show_execution_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Execution Logs'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobOCIDataScience(Job): @@ -2152,6 +2246,8 @@ class JobAzureDatabricks(Job): '_aapi_repr_': 'Parameters'}) idempotency_token: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Idempotency Token'}) + show_tasks_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Tasks 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={ @@ -2302,27 +2398,23 @@ class JobAzureLogicApps(Job): @attrs.define -class JobJenkins(Job): +class JobQlikCloud(Job): - _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) + _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ + '_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'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Parameters'}) - parameters: typing.List[str] = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) - add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Branch Name'}) - branch_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Branch Name'}) + reload_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reload Type'}) + app_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'App ID'}) + print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Print Log 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={ - '_aapi_repr_': 'Failure Tolerance'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) @attrs.define @@ -2352,23 +2444,27 @@ class JobRabbitMQ(Job): @attrs.define -class JobQlikCloud(Job): +class JobJenkins(Job): - _type: str = attrs.field(init=False, default='Job:Qlik Cloud', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Qlik Cloud'}) + _type: str = attrs.field(init=False, default='Job:Jenkins', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Jenkins'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - reload_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reload Type'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - print_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Print Log to Output'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + add_parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Parameters'}) + parameters: typing.List[str] = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Parameters'}) + add_branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Add Branch Name'}) + branch_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Branch Name'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) @attrs.define @@ -2615,32 +2711,6 @@ class JobMicrosoftPowerBISP(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): @@ -2667,6 +2737,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 0890a44..2051da5 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.4.8' +__version__ = '2.4.9' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 0061d70..3e52445 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 = ['ABY122023', 'KBN062023', 'ZFN032022', 'PDY092024', 'GLU062021', 'VMW102024', 'AAR072022', 'AQS012023', 'ODI032024', 'TAB072023', 'ACS042023', 'ASM0220223', 'DBT042023', 'ODF0420241', 'ZRM082023', 'AMM082023', 'ICS032022', 'ZLA112022', 'ABA092022', 'GDU102023', 'UIP072021', 'TDM052022', 'SFI122022', 'ADO112023', 'GBQ102022', 'PBI082024', 'TER102023', 'BAK092023', 'GFU012023', 'NBU032025', 'RMQ082024', 'OVM012024', 'JEN022024', 'GDQ112023', 'ZVM062022', 'AHD062022', 'ADY122023', 'ZDX112021', 'ALM012024', 'ADF062021', 'MBI042022', 'ARS112024', 'NFI042024', 'AEC082022', 'APP022025', 'AWX122024', 'ADS102024', 'MFW022023', 'GCR042024', 'CCI012025', 'ASF012023', 'ASQ032024', 'ASB012025', 'SNF092022', 'MFL022023', 'ODS052024', 'COM032023', 'DSL122024', 'GCC052024', 'ACF082023', 'CMR022024', 'ANS032024', 'ZML022023', 'BOO032022', 'GBA032023', 'ATR122022', 'VNB032025', 'AMW112024', 'AST072024', 'GWF092023', 'RST062023', 'ABK042023', 'ADB112022', 'GDR052023', 'AEM072022', 'SOP072023', 'GDF032022', 'QLC092022', 'AAP092024', 'AAT052023', 'GVM062022', 'AAF112024', 'GDM082023', 'ADP122022', 'DSW122024', 'ZBA042022', 'ZSY062022', 'DBX032022', 'GDP042022', 'TDO042024'] +IF_PLUGINS = ['ATR122022', 'NFI042024', 'ALM012024', 'TER102023', 'CCI012025', 'UIP072021', 'SOP072023', 'AEC082022', 'AMM082023', 'SFI122022', 'GVM062022', 'VNB032025', 'FVT032025', 'DSL122024', 'AAF112024', 'ADB112022', 'PDY092024', 'ASQ032024', 'ANS032024', 'GDQ112023', 'GWF092023', 'GBQ102022', 'ASM0220223', 'KBN062023', 'ADF062021', 'BOO032022', 'ICS032022', 'DBT042023', 'GDP042022', 'ZSY062022', 'ZRM082023', 'ZFN032022', 'NBU032025', 'AWX122024', 'COM032023', 'ASB012025', 'TAB072023', 'ADP122022', 'GDF032022', 'ODI032024', 'GCR042024', 'JEN022024', 'ZDX112021', 'ODS052024', 'ZVM062022', 'GDM082023', 'MFL022023', 'TDO042024', 'DBX032022', 'AAR072022', 'ODF0420241', 'ACS042023', 'GLU062021', 'GDU102023', 'DSW122024', 'AMW112024', 'QLC092022', 'BEC032025', 'VMW102024', 'ADS102024', 'ZML022023', 'ADO112023', 'GDR052023', 'AHD062022', 'MBI042022', 'APP022025', 'ADY122023', 'MFW022023', 'TDM052022', 'ZLA112022', 'ABK042023', 'DTG022025', 'BAK092023', 'SNF092022', 'PBI082024', 'RST062023', 'GCC052024', 'ABY122023', 'AQS012023', 'GFU012023', 'AAT052023', 'RMQ082024', 'CMR022024', 'ABA092022', 'ACF082023', 'ZBA042022', 'ARS112024', 'AST072024', 'OVM012024', 'AEM072022', 'AAP092024', 'ASF012023', 'GBA032023'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index dc4702c..2cded1f 100644 --- a/tests/test_sanity.py +++ b/tests/test_sanity.py @@ -2,6 +2,6 @@ def test_version_author(): import ctm_python_client assert ctm_python_client.__author__ == 'BMC Software' - assert ctm_python_client.__version__ == '2.4.8' + assert ctm_python_client.__version__ == '2.4.9'