diff --git a/.github/workflows/publish.yaml b/.github/workflows/publish.yaml index ca37005..7a15937 100644 --- a/.github/workflows/publish.yaml +++ b/.github/workflows/publish.yaml @@ -18,7 +18,7 @@ jobs: - name: Set up Python uses: actions/setup-python@v3 with: - python-version: '3.7' + python-version: '3.9.21' - name: Install dependencies run: | python -m pip install --upgrade pip diff --git a/.github/workflows/tests.yaml b/.github/workflows/tests.yaml index 6e7acad..79301fa 100644 --- a/.github/workflows/tests.yaml +++ b/.github/workflows/tests.yaml @@ -10,7 +10,7 @@ jobs: strategy: matrix: os: [ubuntu-latest, windows-latest] - python-version: ['3.7'] + python-version: ['3.9.21'] steps: - uses: actions/checkout@v2 diff --git a/setup.py b/setup.py index 995110f..69c9763 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.5", + version="2.4.6", 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 f638504..018c237 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -6,6 +6,20 @@ from aapi import * +@attrs.define +class ConnectionProfileAnsibleAWX(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Ansible AWX', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Ansible AWX'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + ansible_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Ansible URL'}) + ansible_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Ansible Token'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPBatch(ConnectionProfile): @@ -68,6 +82,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): @@ -86,22 +116,6 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileGCPDeploymentManager(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - deployment_manager_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Manager URL'}) - service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileControlMReports(ConnectionProfile): @@ -285,22 +299,6 @@ 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): @@ -325,6 +323,22 @@ class ConnectionProfileAwsQuickSight(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAzureHDInsight(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Name'}) + cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Username'}) + cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cluster Password'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAirbyte(ConnectionProfile): @@ -339,6 +353,20 @@ class ConnectionProfileAirbyte(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileCircleCI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:CircleCI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:CircleCI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + circle_c_i_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'CircleCI URL'}) + 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'}) + + @attrs.define class ConnectionProfileGCPVM(ConnectionProfile): @@ -355,6 +383,28 @@ class ConnectionProfileGCPVM(ConnectionProfile): '_aapi_repr_': 'Connection timeout'}) +@attrs.define +class ConnectionProfileAwsAppRunner(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS App Runner', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS App Runner'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + aws_app_runner_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS App Runner 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 ConnectionProfileAwsSageMaker(ConnectionProfile): @@ -377,6 +427,20 @@ class ConnectionProfileAwsSageMaker(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAstronomer(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Astronomer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Astronomer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + deployment_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Deployment URL'}) + bearer_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bearer Token'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPDataFusion(ConnectionProfile): @@ -449,24 +513,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): @@ -501,40 +547,6 @@ class ConnectionProfileAwsSQS(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}) - 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 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 +569,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): @@ -617,36 +643,6 @@ class ConnectionProfileDatabricks(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureBatchAccounts(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Batch Accounts', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Batch Accounts'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - azure_ad_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure AD url'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - batch_resource_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Resource url'}) - batch_account_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Account Name'}) - batch_region_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Region ID'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureFunctions(ConnectionProfile): @@ -675,6 +671,8 @@ class ConnectionProfileAzureFunctions(ConnectionProfile): '_aapi_repr_': 'Function App Web Site'}) custom_app_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Custom App Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -720,63 +718,53 @@ class ConnectionProfileTableau(ConnectionProfile): @attrs.define -class ConnectionProfileGCPComposer(ConnectionProfile): +class ConnectionProfileGCPDataplex(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - composer_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Composer URL'}) identity_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Identity Type'}) + gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GCP Dataplex URL'}) service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + '_aapi_repr_': 'Connection timeout'}) @attrs.define -class ConnectionProfileGCPDataplex(ConnectionProfile): +class ConnectionProfileGCPComposer(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataplex', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataplex'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Composer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Composer'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) + composer_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Composer URL'}) identity_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Identity Type'}) - gcp_dataplex_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'GCP Dataplex URL'}) service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Service Account Key'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection timeout'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define -class ConnectionProfileAzureVM(ConnectionProfile): +class ConnectionProfileApacheNiFi(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure VM'}) + _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}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login url'}) + 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'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -817,24 +805,6 @@ class ConnectionProfileDBT(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileApacheNiFi(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Apache NiFi'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - ni_fi_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'NiFi URL'}) - port: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Port'}) - username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Username'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -902,19 +872,17 @@ class ConnectionProfileGCPBigQuery(ConnectionProfile): @attrs.define -class ConnectionProfileGCPDataproc(ConnectionProfile): +class ConnectionProfilePagerDuty(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataproc', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataproc'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:PagerDuty', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:PagerDuty'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - identity_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Identity Type'}) - dataproc_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataproc URL'}) - service_account_key__json_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Account Key (JSON Format)'}) + pager_duty_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pager Duty URL'}) + 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'}) + '_aapi_repr_': 'Connection Timeout'}) @attrs.define @@ -931,6 +899,22 @@ class ConnectionProfileTalendDataManagement(ConnectionProfile): '_aapi_repr_': 'Region'}) +@attrs.define +class ConnectionProfileGCPDataproc(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataproc', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataproc'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + dataproc_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataproc URL'}) + service_account_key__json_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key (JSON Format)'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection timeout'}) + + @attrs.define class ConnectionProfileAzureSynapse(ConnectionProfile): @@ -1011,66 +995,6 @@ class ConnectionProfileCommunicationSuite(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureResourceManager(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Resource Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Resource Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login URL'}) - azure_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Base URL'}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - app_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'App ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - -@attrs.define -class ConnectionProfileAzureMachineLearning(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Machine Learning', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Machine Learning'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login URL'}) - azure_management_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Management URL'}) - azure_m_l_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure ML URL'}) - location_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Location Name'}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileAzureDataFactory(ConnectionProfile): @@ -1125,6 +1049,24 @@ class ConnectionProfileOCIDataFlow(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@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 ConnectionProfileAwsStepFunctions(ConnectionProfile): @@ -1167,24 +1109,6 @@ 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): @@ -1235,6 +1159,12 @@ class ConnectionProfileAzureDatabricks(ConnectionProfile): _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Databricks', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Databricks'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Specify Managed Identity Client ID'}) + managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Managed Identity Client ID'}) tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Tenant ID'}) application_id: str = attrs.field(kw_only=True, default=None, metadata={ @@ -1251,19 +1181,20 @@ class ConnectionProfileAzureDatabricks(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) - @attrs.define -class ConnectionProfileTerraform(ConnectionProfile): +class ConnectionProfileApplicationIntegratorAISimplePlugin(ConnectionProfileApplicationIntegrator): - _type: str = attrs.field(init=False, default='ConnectionProfile:Terraform', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Terraform'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:ApplicationIntegrator:AI Simple Plugin', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:ApplicationIntegrator:AI Simple Plugin'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - terraform_org_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Terraform Org Name'}) - token: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + ai_run_as: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Run As'}) + ai_run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-RunAs-Pass'}) + ai_host: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Host'}) + ai_machine_password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Machine Password'}) @attrs.define @@ -1321,47 +1252,19 @@ class ConnectionProfileGCPFunctions(ConnectionProfile): @attrs.define -class ConnectionProfileAzureLogicApps(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure Logic Apps', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure Logic Apps'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Subscription ID'}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - specify_managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Specify Managed Identity Client ID'}) - managed_identity_client_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Managed Identity Client ID'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tenant ID'}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Azure Login URL'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - -@attrs.define -class ConnectionProfileQlikCloud(ConnectionProfile): +class ConnectionProfileRabbitMQ(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:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:RabbitMQ'}) 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'}) + rabbit_m_q_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'RabbitMQ 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'}) @@ -1383,23 +1286,21 @@ class ConnectionProfileJenkins(ConnectionProfile): @attrs.define -class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): +class ConnectionProfileQlikCloud(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + _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}) - application_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Application ID'}) - client_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Client Secret'}) - user_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'User Name'}) - password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Password'}) - resource_group: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group'}) - api_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API URL'}) + 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'}) @attrs.define @@ -1430,6 +1331,26 @@ class ConnectionProfileAzureBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Name'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + + @attrs.define class ConnectionProfileSnowflake(ConnectionProfile): @@ -1478,6 +1399,32 @@ class ConnectionProfileOCIVM(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerBISP(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI SP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI SP'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + power_b_i_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Power BI URL'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + 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'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + user_name: 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'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsDataPipeline(ConnectionProfile): @@ -1500,34 +1447,6 @@ class ConnectionProfileAwsDataPipeline(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileOCIDataIntegration(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:OCI Data Integration', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:OCI Data Integration'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - oci_data_integration_url: str = attrs.field( - kw_only=True, default=None, metadata={'_aapi_repr_': 'OCI Data Integration 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'}) - profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Profile'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileMicroFocusWindows(ConnectionProfile): @@ -1546,3 +1465,19 @@ class ConnectionProfileMicroFocusWindows(ConnectionProfile): '_aapi_repr_': 'Run As'}) run_as_pass: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'RunAs-Pass'}) + + +@attrs.define +class ConnectionProfileGCPCloudRun(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Cloud Run', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Cloud Run'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) + cloud_run_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Cloud Run 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'}) diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index 02f7dec..1ae11bd 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -6,6 +6,40 @@ from aapi import * +@attrs.define +class JobAnsibleAWX(Job): + + _type: str = attrs.field(init=False, default='Job:Ansible AWX', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Ansible AWX'}) + 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'}) + job_template_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Template Name'}) + job_template_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Template ID'}) + workflow_template_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow Template Name'}) + inventory: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Inventory'}) + inventory_source: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Inventory Source'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + project_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Name'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project ID'}) + output_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output 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 JobGCPBatch(Job): @@ -124,8 +158,22 @@ class JobAwsMainframeModernization(Job): '_aapi_repr_': 'Action'}) jcl_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'JCL Name'}) + rerun_execution_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Execution ID'}) + secret_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Secret ARN'}) + from_step: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'From Step'}) + from_proc_step: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'From Proc Step'}) + to_step: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'To Step'}) + to_proc_step: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'To Proc Step'}) retrieve_cloud_watch_logs: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Retrieve CloudWatch Logs'}) + delay_logs_retrieval_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Delay Logs Retrieval '}) application_action: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Application Action'}) client_token: str = attrs.field(kw_only=True, default=None, metadata={ @@ -144,6 +192,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): @@ -174,28 +244,6 @@ class JobAzureDevOps(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobGCPDeploymentManager(Job): - - _type: str = attrs.field(init=False, default='Job:GCP Deployment Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Deployment Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - deployment_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Name'}) - yaml_config_content: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Yaml Config Content'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobControlMReports(Job): @@ -299,7 +347,6 @@ class JobAwsEC2(Job): get_instances_logs: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Get Instances logs'}) - @attrs.define class JobTalendOAuth(Job): @@ -369,17 +416,17 @@ class JobAwsBackup(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={ @@ -387,17 +434,17 @@ class JobAzureHDInsight(Job): @attrs.define -class JobAwsQuickSight(Job): +class JobAzureHDInsight(Job): - _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) + _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Dataset ID'}) - refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Refresh Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bring job logs to output'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -424,6 +471,30 @@ class JobAirbyte(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobCircleCI(Job): + + _type: str = attrs.field(init=False, default='Job:CircleCI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:CircleCI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + project_slug: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Slug'}) + workflow_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow ID'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + 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 JobGCPVM(Job): @@ -452,6 +523,26 @@ class JobGCPVM(Job): '_aapi_repr_': 'Get Logs'}) +@attrs.define +class JobAwsAppRunner(Job): + + _type: str = attrs.field(init=False, default='Job:AWS App Runner', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS App Runner'}) + 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'}) + service_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Arn'}) + output_job_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Output Job Logs'}) + failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance '}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + + @attrs.define class JobAwsSageMaker(Job): @@ -478,6 +569,26 @@ class JobAwsSageMaker(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAstronomer(Job): + + _type: str = attrs.field(init=False, default='Job:Astronomer', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Astronomer'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + d_a_g_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_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'}) + 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 JobGCPDataFusion(Job): @@ -558,12 +669,12 @@ class JobAwsSNS(Job): '_aapi_repr_': 'Message Group ID'}) attributes: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Attributes'}) - attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) - attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) - attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) - attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) - attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) - attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) + attribute.1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) + attribute.1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) + attribute.2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) + attribute.2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) + attribute.3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) + attribute.3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) sms_attributes: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'SMS Attributes'}) sender_identifier: str = attrs.field(kw_only=True, default=None, metadata={ @@ -578,16 +689,16 @@ class JobAwsSNS(Job): '_aapi_repr_': 'SMS Type'}) push_notifications_attributes: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Push Notifications Attributes'}) - push_attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.1 Name'}) - push_attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.1 Value'}) - push_attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.2 Name'}) - push_attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.2 Value'}) - push_attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.3 Name'}) - push_attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.3 Value'}) - push_attribute4_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.4 Name'}) - push_attribute4_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.4 Value'}) - push_attribute5_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Name'}) - push_attribute5_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Value'}) + push_attribute.1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.1 Name'}) + push_attribute.1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.1 Value'}) + push_attribute.2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.2 Name'}) + push_attribute.2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.2 Value'}) + push_attribute.3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.3 Name'}) + push_attribute.3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.3 Value'}) + push_attribute.4_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.4 Name'}) + push_attribute.4_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.4 Value'}) + push_attribute.5_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Name'}) + push_attribute.5_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'PushAttribute.5 Value'}) @attrs.define @@ -608,30 +719,6 @@ class JobAwsLambda(Job): '_aapi_repr_': 'Append Log to Output'}) -@attrs.define -class JobUIPath(Job): - - _type: str = attrs.field(init=False, default='Job:UI Path', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:UI Path'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - folder_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Name'}) - folder_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Folder Id'}) - process_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Process Name'}) - robot_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Name'}) - robot_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Robot Id'}) - optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Optional Input Parameters'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - @attrs.define class JobAlteryxTrifacta(Job): @@ -680,99 +767,33 @@ class JobAwsSQS(Job): '_aapi_repr_': 'Message Group ID'}) message_attributes: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Message Attributes'}) - attribute1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) - attribute1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) - attribute1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) - attribute2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) - attribute2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) - attribute2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) - attribute3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) - attribute3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) - attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) + attribute.1_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Name'}) + attribute.1_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 DataType'}) + attribute.1_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.1 Value'}) + attribute.2_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Name'}) + attribute.2_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 DataType'}) + attribute.2_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.2 Value'}) + attribute.3_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Name'}) + attribute.3_data_type: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 DataType'}) + attribute.3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) @attrs.define -class JobSnowflakeIdP(Job): +class JobAwsGlue(Job): - _type: str = attrs.field(init=False, default='Job:Snowflake IdP', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Snowflake IdP'}) + _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'}) - database: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Database'}) - schema: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Schema'}) - select_operation: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Select Operation'}) - snowflake_sql_statement: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Snowflake SQL Statement'}) - query_to_location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Query To Location'}) - query_input: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Query Input'}) - storage_integration: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Storage Integration'}) - overwrite: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Overwrite'}) - file_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'File Format'}) - create_table_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Create Table Name'}) - query: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Query'}) - add_condition: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Add Condition'}) - stored_procedure_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stored Procedure Name'}) - procedure_argument: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Procedure Argument'}) - activity_options: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Activity Options'}) - table_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Table Name'}) - from_location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'From Location'}) - stage_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stage Name'}) - from_storage_integration: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'From Storage Integration'}) - stage_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stage URL'}) - copy_destination: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Copy Destination'}) - from_table: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'From Table'}) - pipe_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipe Name'}) - start_or_pause_pipe: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Start Or Pause Pipe'}) - stage_location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stage Location'}) - snowpipe_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Snowpipe Name'}) - days_back: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Days Back'}) - status_file_cloud_location_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status File Cloud Location Path'}) - stoarge_integration_for_location: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stoarge Integration For Location'}) - statement_timeout__sec: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Statement Timeout (Sec)'}) - show_more_options: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show More Options'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - role: str = attrs.field(kw_only=True, default=None, - metadata={'_aapi_repr_': 'Role'}) - bindings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bindings'}) - warehouse: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Warehouse'}) - show_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Show Output'}) - polling_interval__sec: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Polling Interval (Sec)'}) + glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Job Name'}) + glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Glue Job Arguments'}) + arguments: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Arguments'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Failure Tolerance'}) @@ -799,26 +820,6 @@ class JobGCPDataprep(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsGlue(Job): - - _type: str = attrs.field(init=False, default='Job:AWS Glue', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Glue'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - glue_job_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Glue Job Name'}) - glue_job_arguments: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Glue Job Arguments'}) - arguments: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Arguments'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsGlueDataBrew(Job): @@ -885,46 +886,8 @@ class JobDatabricks(Job): '_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): - - _type: str = attrs.field(init=False, default='Job:Azure Batch Accounts', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Batch Accounts'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - batch_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch Job ID'}) - task_id_prefix: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task ID Prefix'}) - task_command_line: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task Command Line'}) - max_wall_clock_time: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Max Wall Clock Time'}) - max_wall_time_digits: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Max Wall Time Digits'}) - max_wall_time_unit: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Max Wall Time Unit'}) - max_task_retry_count: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Max Task Retry Count'}) - retry_number: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retry Number'}) - retention_time: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retention Time'}) - retention_time_digits: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retention Time Digits'}) - retention_time_unit: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Retention Time Unit'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log to Output'}) - status_polling_interval: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status polling interval'}) - task_id_variable: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Task ID variable'}) - content_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Content-Type'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) @attrs.define @@ -937,6 +900,10 @@ class JobAzureFunctions(Job): '_aapi_repr_': 'ConnectionProfile'}) function_app: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Function App'}) + azure_resource: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Resource'}) + azure_resource_scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure resource scope'}) function_name: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Function Name'}) optional_input_parameters: str = attrs.field(kw_only=True, default=None, metadata={ @@ -947,6 +914,8 @@ class JobAzureFunctions(Job): '_aapi_repr_': 'Verification Poll Intervall'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Failure Tolerance'}) + api_v_e_r_s_i_o_n: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API-VERSION'}) @attrs.define @@ -998,27 +967,7 @@ class JobTableau(Job): @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'}) - dag_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Name'}) - dag_run_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DAG Run ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - 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): +class JobGCPDataplex(Job): _type: str = attrs.field(init=False, default='Job:GCP Dataplex', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataplex'}) @@ -1044,27 +993,47 @@ class JobGCPDataplex(Job): @attrs.define -class JobAzureVM(Job): +class JobGCPComposer(Job): - _type: str = attrs.field(init=False, default='Job:Azure VM', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure VM'}) + _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'}) - 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'}) + 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'}) + 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): + + _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor Group ID'}) + processor_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Processor ID'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Disconnected Node Ack'}) + parameters_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters '}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) @attrs.define @@ -1137,30 +1106,6 @@ class JobDBT(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobApacheNiFi(Job): - - _type: str = attrs.field(init=False, default='Job:Apache NiFi', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Apache NiFi'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - processor_group_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor Group ID'}) - processor_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Processor ID'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - disconnected_node_ack: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Disconnected Node Ack'}) - parameters_: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters '}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobAwsBatch(Job): @@ -1286,31 +1231,33 @@ class JobGCPBigQuery(Job): @attrs.define -class JobGCPDataproc(Job): +class JobPagerDuty(Job): - _type: str = attrs.field(init=False, default='Job:GCP Dataproc', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataproc'}) + _type: str = attrs.field(init=False, default='Job:PagerDuty', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:PagerDuty'}) 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'}) - account_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Account Region'}) - dataproc_task_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataproc task type'}) - batch_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Batch ID'}) - request_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Request ID'}) - workflow_template: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workflow Template'}) - parameters__json_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters (JSON Format)'}) - verification_poll_interval_in_seconds: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Verification Poll Interval (in seconds)'}) - tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Tolerance'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + incident_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Incident ID'}) + email_address: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Email Address'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + duration: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Duration'}) + title: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Title'}) + service_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service ID'}) + urgency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Urgency'}) + incident_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Incident Key'}) + incident_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Incident Body'}) @attrs.define @@ -1339,6 +1286,34 @@ class JobTalendDataManagement(Job): '_aapi_repr_': 'Plan Polling Intervals'}) +@attrs.define +class JobGCPDataproc(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Dataproc', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataproc'}) + 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'}) + account_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Region'}) + dataproc_task_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataproc task type'}) + batch_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Batch ID'}) + request_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Request ID'}) + workflow_template: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow Template'}) + parameters__json_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters (JSON Format)'}) + verification_poll_interval_in_seconds: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Verification Poll Interval (in seconds)'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + + @attrs.define class JobAzureSynapse(Job): @@ -1421,56 +1396,6 @@ class JobCommunicationSuite(Job): '_aapi_repr_': 'Teams Parameters'}) -@attrs.define -class JobAzureResourceManager(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Resource Manager', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Resource Manager'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - resource_group_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group Name'}) - 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'}) - deployment_properties: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Deployment Properties'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - -@attrs.define -class JobAzureMachineLearning(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Machine Learning', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Machine Learning'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - resource_group_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Resource Group Name'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - pipeline_endpoint_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Endpoint ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - compute_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Compute Name'}) - compute_action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Compute Action'}) - 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): @@ -1511,6 +1436,40 @@ class JobOCIDataFlow(Job): '_aapi_repr_': 'Failure Tolerance'}) +@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 JobAwsStepFunctions(Job): @@ -1569,40 +1528,6 @@ 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): @@ -1659,32 +1584,24 @@ class JobAzureDatabricks(Job): '_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={ + '_aapi_repr_': 'Failure Tolerance'}) @attrs.define -class JobTerraform(Job): +class JobApplicationIntegratorAISimplePlugin(JobApplicationIntegrator): - _type: str = attrs.field(init=False, default='Job:Terraform', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Terraform'}) + _type: str = attrs.field(init=False, default='Job:ApplicationIntegrator:AI Simple Plugin', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:ApplicationIntegrator:AI Simple Plugin'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - action: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Action'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - run_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run Name'}) - variables: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Variables'}) - workspace_params: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Params'}) - variable: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Variable'}) - 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'}) + ai_connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-ConnectionProfile'}) + ai_user: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-User'}) + ai_connection_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AI-Connection Type'}) @attrs.define @@ -1778,43 +1695,29 @@ class JobGCPFunctions(Job): @attrs.define -class JobAzureLogicApps(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Logic Apps', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Logic Apps'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - workflow: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workflow'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - get_logs: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Get Logs'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - - -@attrs.define -class JobQlikCloud(Job): +class JobRabbitMQ(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:RabbitMQ', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:RabbitMQ'}) 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'}) - 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'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + vhost: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Vhost'}) + exchange: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Exchange'}) + routing_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Routing Key'}) + message_to_publish: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message to Publish'}) + message_encoding: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Encoding'}) + properties: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Properties'}) + queue: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Queue'}) @attrs.define @@ -1842,29 +1745,23 @@ class JobJenkins(Job): @attrs.define -class JobMicrosoftPowerBI(Job): +class JobQlikCloud(Job): - _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + _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'}) - dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) - dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) + 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'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) @attrs.define @@ -1905,6 +1802,32 @@ class JobAzureBackup(Job): '_aapi_repr_': 'Failure Tolerance '}) +@attrs.define +class JobMicrosoftPowerBI(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) + workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace Name'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + + @attrs.define class JobSnowflake(Job): @@ -2010,25 +1933,33 @@ class JobOCIVM(Job): @attrs.define -class JobAwsDataPipeline(Job): +class JobMicrosoftPowerBISP(Job): - _type: str = attrs.field(init=False, default='Job:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Data Pipeline'}) + _type: str = attrs.field(init=False, default='Job:Microsoft Power BI SP', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI SP'}) 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'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Name'}) - pipeline_unique_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline Unique ID'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID'}) + dataflow_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataflow ID'}) + workspace_id__s_p: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID - SP'}) + dataset_id__s_p: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID - SP'}) + dataflow_id__s_p: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataflow ID - SP'}) parameters: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Parameters'}) - trigger_created_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Trigger Created Pipeline'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + pipeline_id__s_p: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID - SP'}) 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={ @@ -2036,25 +1967,25 @@ class JobAwsDataPipeline(Job): @attrs.define -class JobOCIDataIntegration(Job): +class JobAwsDataPipeline(Job): - _type: str = attrs.field(init=False, default='Job:OCI Data Integration', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:OCI Data Integration'}) + _type: str = attrs.field(init=False, default='Job:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Data Pipeline'}) 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'}) + action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Action'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + pipeline_unique_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Unique ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + trigger_created_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Trigger Created Pipeline'}) 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={ @@ -2101,3 +2032,23 @@ class JobMicroFocusWindows(Job): '_aapi_repr_': 'Restart with Modified JCL'}) modified_jcl_path_and_filename: str = attrs.field( kw_only=True, default=None, metadata={'_aapi_repr_': 'Modified JCL Path and Filename'}) + + +@attrs.define +class JobGCPCloudRun(Job): + + _type: str = attrs.field(init=False, default='Job:GCP Cloud Run', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Cloud Run'}) + 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'}) + job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Name'}) + overrides_specification: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Overrides Specification'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 3a7813f..d63c8cd 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.4.5' +__version__ = '2.4.6' __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 d3c57ce..c5f7c59 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 = ['TAB072023', 'AAR072022', 'GBA032023', 'DBX032022', 'TDM052022', 'ZBA042022', 'ASQ032024', 'ABK042023', 'QLC092022', 'ASF012023', 'ODI032024', 'MFW022023', 'JEN022024', 'AEM072022', 'RST062023', 'MFL022023', 'COM032023', 'AMM082023', 'AQS012023', 'ALM012024', 'UIP072021', 'ZFN032022', 'AHD062022', 'GVM062022', 'OVM012024', 'GWF092023', 'ACS042023', 'ZVM062022', 'ANS032024', 'MBI042022', 'ODF0420241', 'GDU102023', 'ODS052024', 'GCC052024', 'ZRM082023', 'ZML022023', 'ZLA112022', 'GDF032022', 'ASM0220223', 'NFI042024', 'ABY122023', 'ICS032022', 'CMR022024', 'ADB112022', 'TDO042024', 'ZDX112021', 'GBQ102022', 'ADP122022', 'GDR052023', 'GLU062021', 'ZSY062022', 'DBT042023', 'AEC082022', 'TER102023', 'SNF092022', 'ACF082023', 'AAT052023', 'ATR122022', 'KBN062023', 'GDP042022', 'SFI122022', 'ADY122023', 'GDM082023', 'BAK092023', 'BOO032022', 'SOP072023', 'ADF062021', 'GFU012023', 'ADO112023', 'ABA092022', 'GDQ112023'] +IF_PLUGINS = ['ZVM062022', 'AAT052023', 'ADO112023', 'ZBA042022', 'GCR042024', 'GDU102023', 'ASF012023', 'AAR072022', 'ODS052024', 'TER102023', 'ACF082023', 'AAP092024', 'ZLA112022', 'ODF0420241', 'GBA032023', 'CMR022024', 'ALM012024', 'OVM012024', 'COM032023', 'JEN022024', 'BAK092023', 'AEC082022', 'QLC092022', 'ABK042023', 'CCI012025', 'ATR122022', 'ZML022023', 'AQS012023', 'UIP072021', 'ADP122022', 'ASQ032024', 'ACS042023', 'GDM082023', 'AWX122024', 'ABA092022', 'MFL022023', 'ABY122023', 'RMQ082024', 'PBI082024', 'ZFN032022', 'GVM062022', 'NFI042024', 'RST062023', 'AHD062022', 'MFW022023', 'ZDX112021', 'ANS032024', 'DBX032022', 'GLU062021', 'GWF092023', 'GDR052023', 'ICS032022', 'ADY122023', 'MBI042022', 'AEM072022', 'ADF062021', 'TDM052022', 'GDP042022', 'TAB072023', 'ODI032024', 'GCC052024', 'ADB112022', 'DBT042023', 'SOP072023', 'SNF092022', 'AMM082023', 'BOO032022', 'GFU012023', 'GDF032022', 'AST072024', 'PDY092024', 'KBN062023', 'SFI122022', 'ZRM082023', 'GDQ112023', 'ASM0220223', 'GBQ102022', 'ZSY062022', 'TDO042024'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 911c3c1..3ef92bd 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.5' + assert ctm_python_client.__version__ == '2.4.6'