diff --git a/setup.py b/setup.py index 4e34aa6..a435a76 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.5.4", + version="2.5.5", description="Python Workflows for Control-M", long_description=long_description, long_description_content_type='text/markdown', diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py index 99de7a2..0c6a020 100644 --- a/src/aapi/integration_factory/connection_profiles.py +++ b/src/aapi/integration_factory/connection_profiles.py @@ -40,22 +40,22 @@ class ConnectionProfileGCPVertexAI(ConnectionProfile): object_name: str = attrs.field(metadata={'_aapi_name_': True}) identitty_type: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Identitty Type'}) - type_of_service: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Type of Service'}) + service_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Type'}) gcp_vertex_ai__url: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'GCP Vertex AI URL'}) gcp_vertex_ai_url: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'GCP Vertex AI URL'}) location: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Location'}) - service_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Key'}) + service_account_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Account Key'}) http_codes: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'HTTP Codes'}) rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Rerun Interval'}) - attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Attempt Reruns'}) + rerun_attempts_: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Attempts '}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -82,6 +82,22 @@ class ConnectionProfileAwsDynamoDB(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): @@ -92,26 +108,24 @@ class ConnectionProfileAzureDevOps(ConnectionProfile): '_aapi_repr_': 'Azure DevOps URL'}) organization_id: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Organization ID'}) + identity_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Identity Type'}) azure_username: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Azure Username'}) azure_devops_token: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Azure Devops Token'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_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'}) + subscription_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Subscription ID'}) + azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Login URL'}) + tenant_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tenant ID'}) + scope: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Scope'}) + 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'}) @@ -658,6 +672,38 @@ class ConnectionProfileGCPDataflow(ConnectionProfile): '_aapi_repr_': 'Service Account Key'}) +@attrs.define +class ConnectionProfileAwsBedrock(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Bedrock', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Bedrock'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + bedrock_agent_runtime_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bedrock Agent Runtime 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'}) + assume_role_arn: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role ARN'}) + assume_role_session: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Assume Role Session'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + + @attrs.define class ConnectionProfileAwsMWAA(ConnectionProfile): @@ -710,6 +756,32 @@ class ConnectionProfileVeritasNetBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMatillion(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Matillion', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Matillion'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + environment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Environment'}) + matillion_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Matillion Base URL'}) + 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'}) + matillion_e_t_l_instance_url: str = attrs.field( + kw_only=True, default=None, metadata={'_aapi_repr_': 'Matillion ETL Instance 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 ConnectionProfileGCPDataproc(ConnectionProfile): @@ -992,6 +1064,28 @@ class ConnectionProfileAzureDatabricks(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) +@attrs.define +class ConnectionProfileGitHubActions(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:GitHub Actions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GitHub Actions'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + git_hub_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'GitHub URL'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Token'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempts_rerun: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempts Rerun'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsECS(ConnectionProfile): @@ -1068,6 +1162,38 @@ class ConnectionProfileRabbitMQ(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftFabric(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Fabric', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Fabric'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + 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'}) + azure_login_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Azure Login URL'}) + fabric_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fabric URL'}) + 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'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + attempt_reruns: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Attempt Reruns'}) + + @attrs.define class ConnectionProfileAwsRedshift(ConnectionProfile): @@ -1116,6 +1242,26 @@ class ConnectionProfileVeeamBackup(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileMicrosoftPowerBI(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + application_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Application ID'}) + client_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Client Secret'}) + user_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'User Name'}) + password: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Password'}) + resource_group: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Resource Group'}) + api_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API URL'}) + + @attrs.define class ConnectionProfileAzureBackup(ConnectionProfile): @@ -1144,36 +1290,20 @@ 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): _type: str = attrs.field(init=False, default='ConnectionProfile:Snowflake', metadata={ '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Snowflake'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) + snowflake_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Snowflake URL'}) account_identifier: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Account Identifier'}) region: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Region'}) + authentication_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Type'}) 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={ @@ -1182,6 +1312,8 @@ class ConnectionProfileSnowflake(ConnectionProfile): '_aapi_repr_': 'Refresh Token'}) redirect_url: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Redirect URL'}) + access_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Access Token'}) @attrs.define @@ -1489,6 +1621,22 @@ class ConnectionProfileTalendOAuth(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): @@ -1513,22 +1661,6 @@ class ConnectionProfileAwsQuickSight(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAzureHDInsight(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Azure HDInsight'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - cluster_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Name'}) - cluster_username: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Username'}) - cluster_password: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Cluster Password'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileCircleCI(ConnectionProfile): @@ -1798,6 +1930,30 @@ class ConnectionProfileAlteryxTrifacta(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileIBMDataStageWindows(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + server_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Server Name'}) + domain_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Domain Name'}) + 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'}) + authentication_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication File'}) + empty: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty'}) + d_s_j_o_b_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DSJOB Path'}) + + @attrs.define class ConnectionProfileAwsSQS(ConnectionProfile): @@ -1824,30 +1980,6 @@ class ConnectionProfileAwsSQS(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileIBMDataStageWindows(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication Method'}) - server_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Server Name'}) - domain_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Domain Name'}) - 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'}) - authentication_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication File'}) - empty: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty'}) - d_s_j_o_b_path: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DSJOB Path'}) - - @attrs.define class ConnectionProfileSnowflakeIdP(ConnectionProfile): @@ -1944,28 +2076,6 @@ class ConnectionProfileDatabricks(ConnectionProfile): '_aapi_repr_': 'Attempt Reruns'}) -@attrs.define -class ConnectionProfileAwsAthena(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Athena', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Athena'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - aws_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Base URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret Key'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileDBT(ConnectionProfile): @@ -1983,15 +2093,23 @@ class ConnectionProfileDBT(ConnectionProfile): @attrs.define -class ConnectionProfileFivetran(ConnectionProfile): +class ConnectionProfileAwsAthena(ConnectionProfile): - _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Athena', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Athena'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) - fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Fivetran Base URL'}) - api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'API Base 64 Key'}) + aws_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Base URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret Key'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Connection Timeout'}) @@ -2024,6 +2142,20 @@ class ConnectionProfileAzureServiceBus(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileFivetran(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Fivetran', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Fivetran'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + fivetran_base_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Fivetran Base URL'}) + api_base_64_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Base 64 Key'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAwsBatch(ConnectionProfile): @@ -2273,6 +2405,30 @@ class ConnectionProfileGCPFunctions(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAtlassianBitbucket(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:Atlassian Bitbucket', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:Atlassian Bitbucket'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + bitbucket_rest_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Bitbucket REST URL'}) + authentication_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication Method'}) + account_email: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Account Email'}) + api_token: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'API Token'}) + http_codes: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'HTTP Codes'}) + rerun_interval: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Interval'}) + rerun_attempts: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Attempts'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileAzureLogicApps(ConnectionProfile): @@ -2353,28 +2509,6 @@ class ConnectionProfileOCIVM(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) -@attrs.define -class ConnectionProfileAwsDataPipeline(ConnectionProfile): - - _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Data Pipeline URL'}) - aws_region: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Region'}) - authentication: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Authentication'}) - aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Access Key'}) - aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'AWS Secret'}) - iam_role: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'IAM Role'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - - @attrs.define class ConnectionProfileOCIDataIntegration(ConnectionProfile): @@ -2403,6 +2537,28 @@ class ConnectionProfileOCIDataIntegration(ConnectionProfile): '_aapi_repr_': 'Connection Timeout'}) +@attrs.define +class ConnectionProfileAwsDataPipeline(ConnectionProfile): + + _type: str = attrs.field(init=False, default='ConnectionProfile:AWS Data Pipeline', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS Data Pipeline'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + data_pipeline_url: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Data Pipeline URL'}) + aws_region: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Region'}) + authentication: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Authentication'}) + aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Access Key'}) + aws_secret: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Secret'}) + iam_role: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'IAM Role'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + + @attrs.define class ConnectionProfileGCPCloudRun(ConnectionProfile): diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py index caaf40f..8a564ff 100644 --- a/src/aapi/integration_factory/jobs.py +++ b/src/aapi/integration_factory/jobs.py @@ -108,6 +108,28 @@ class JobAwsDynamoDB(Job): '_aapi_repr_': 'Failure Tolarance '}) +@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): @@ -138,28 +160,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 JobAwsEC2(Job): @@ -868,6 +868,36 @@ class JobGCPDataflow(Job): '_aapi_repr_': 'Log Level'}) +@attrs.define +class JobAwsBedrock(Job): + + _type: str = attrs.field(init=False, default='Job:AWS Bedrock', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS Bedrock'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + flow_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Id'}) + alias: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Alias'}) + flow_text_input: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Flow Text Input'}) + input_node_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Input Node Name'}) + initial_node_output_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Initial Node Output Name'}) + latency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Latency'}) + show_execution_events: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Show Execution Events'}) + event_type_presentation: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Event Type Presentation'}) + 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 JobAwsMWAA(Job): @@ -936,6 +966,36 @@ class JobVeritasNetBackup(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobMatillion(Job): + + _type: str = attrs.field(init=False, default='Job:Matillion', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Matillion'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + matillion_job_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Matillion Job Type'}) + project_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Id'}) + environment_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Environment Name'}) + pipeline_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline Name'}) + group_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Group Name'}) + project_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project Name'}) + version_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Version Name'}) + job_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Name'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Tolerance'}) + + @attrs.define class JobGCPDataproc(Job): @@ -1244,6 +1304,66 @@ class JobAzureDatabricks(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobGitHubActions(Job): + + _type: str = attrs.field(init=False, default='Job:GitHub Actions', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GitHub Actions'}) + 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'}) + pull_request_actions: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pull Request Actions'}) + workflow_action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow Action'}) + rerun_options: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Rerun Options'}) + repository_owner: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Repository Owner'}) + repository_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Repository Name'}) + workflow_file_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workflow File Name'}) + reference: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reference'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + run_attempt_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Attempt ID'}) + job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job ID'}) + get_workflow_logs: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Workflow Logs'}) + p_r_title: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'PR Title'}) + p_r_head: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'PR Head'}) + p_r_base: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'PR Base'}) + p_r_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'PR Body'}) + draft: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Draft'}) + maintainer_can_modify: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Maintainer Can Modify'}) + p_r_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'PR ID'}) + commit_title: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Commit Title'}) + commit_message: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Commit Message'}) + commit_s_h_a: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Commit SHA'}) + merge_method: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Merge Method'}) + 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 JobAwsECS(Job): @@ -1362,6 +1482,28 @@ class JobRabbitMQ(Job): '_aapi_repr_': 'Queue'}) +@attrs.define +class JobMicrosoftFabric(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Fabric', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Fabric'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + item_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Item ID'}) + job_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Type'}) + execution_data_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Execution Data Body'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsRedshift(Job): @@ -1422,6 +1564,32 @@ class JobVeeamBackup(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobMicrosoftPowerBI(Job): + + _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) + workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace Name'}) + workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace ID'}) + dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Dataset ID'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Connection Timeout'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pipeline ID'}) + + @attrs.define class JobAzureBackup(Job): @@ -1460,32 +1628,6 @@ class JobAzureBackup(Job): '_aapi_repr_': 'Failure Tolerance '}) -@attrs.define -class JobMicrosoftPowerBI(Job): - - _type: str = attrs.field(init=False, default='Job:Microsoft Power BI', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Microsoft Power BI'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - dataset_refresh_pipeline_deployment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset Refresh/ Pipeline Deployment'}) - workspace_name: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace Name'}) - workspace_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Workspace ID'}) - dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Dataset ID'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Connection Timeout'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - pipeline_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Pipeline ID'}) - - @attrs.define class JobSnowflake(Job): @@ -1953,17 +2095,17 @@ class JobTalendOAuth(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={ @@ -1971,17 +2113,17 @@ class JobAwsQuickSight(Job): @attrs.define -class JobAzureHDInsight(Job): +class JobAwsQuickSight(Job): - _type: str = attrs.field(init=False, default='Job:Azure HDInsight', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure HDInsight'}) + _type: str = attrs.field(init=False, default='Job:AWS QuickSight', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:AWS QuickSight'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - bring_job_logs_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Bring job logs to output'}) + aws_dataset_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'AWS Dataset ID'}) + refresh_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Refresh Type'}) status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'Status Polling Frequency'}) failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ @@ -2234,6 +2376,40 @@ class JobAlteryxTrifacta(Job): '_aapi_repr_': 'Status Polling Frequency'}) +@attrs.define +class JobIBMDataStageWindows(Job): + + _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + project: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Project'}) + datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Datastage Job'}) + job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Job Invocation ID (Optional)'}) + parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters Type'}) + parameters: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameters'}) + parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Parameter File'}) + stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Stop Stages After Number Of Rows'}) + abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Abort Job After Number Of Warnings'}) + append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Append Log To Output'}) + run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run In Restart Mode'}) + reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reset Job Before Run'}) + empty1: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Empty1'}) + + @attrs.define class JobAwsSQS(Job): @@ -2271,40 +2447,6 @@ class JobAwsSQS(Job): attribute3_value: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'Attribute.3 Value'}) -@attrs.define -class JobIBMDataStageWindows(Job): - - _type: str = attrs.field(init=False, default='Job:IBM DataStage Windows', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:IBM DataStage Windows'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - project: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Project'}) - datastage_job: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Datastage Job'}) - job_invocation_id__optional: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Job Invocation ID (Optional)'}) - parameters_type: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters Type'}) - parameters: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameters'}) - parameter_file: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Parameter File'}) - stop_stages_after_number_of_rows: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Stop Stages After Number Of Rows'}) - abort_job_after_number_of_warnings: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Abort Job After Number Of Warnings'}) - append_log_to_output: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Append Log To Output'}) - run_in_restart_mode: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run In Restart Mode'}) - reset_job_before_run: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Reset Job Before Run'}) - empty1: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Empty1'}) - - @attrs.define class JobSnowflakeIdP(Job): @@ -2461,6 +2603,28 @@ class JobDatabricks(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobDBT(Job): + + _type: str = attrs.field(init=False, default='Job:DBT', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) + object_name: str = attrs.field(metadata={'_aapi_name_': True}) + connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'ConnectionProfile'}) + dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'DBT Job Id'}) + run_comment: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Run Comment'}) + override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Override Job Commands'}) + define_commands: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Define Commands'}) + status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Status Polling Frequency'}) + failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobAwsAthena(Job): @@ -2510,25 +2674,20 @@ class JobAwsAthena(Job): @attrs.define -class JobDBT(Job): +class JobAzureServiceBus(Job): - _type: str = attrs.field(init=False, default='Job:DBT', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:DBT'}) + _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) object_name: str = attrs.field(metadata={'_aapi_name_': True}) connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ '_aapi_repr_': 'ConnectionProfile'}) - dbt_job_id: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'DBT Job Id'}) - run_comment: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Run Comment'}) - override_job_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Override Job Commands'}) - define_commands: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Define Commands'}) - status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Status Polling Frequency'}) - failure_tolerance: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Failure Tolerance'}) + service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Service Bus Namespace'}) + queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) + message_format: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Format'}) + message_body: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message Body'}) @attrs.define @@ -2555,23 +2714,6 @@ class JobFivetran(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAzureServiceBus(Job): - - _type: str = attrs.field(init=False, default='Job:Azure Service Bus', metadata={ - '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Service Bus'}) - object_name: str = attrs.field(metadata={'_aapi_name_': True}) - connection_profile: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'ConnectionProfile'}) - service_bus_namespace: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Service Bus Namespace'}) - queue_topic_name: str = attrs.field(kw_only=True, default=None, metadata={'_aapi_repr_': 'QueueTopic Name'}) - message_format: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Format'}) - message_body: str = attrs.field(kw_only=True, default=None, metadata={ - '_aapi_repr_': 'Message Body'}) - - @attrs.define class JobAwsBatch(Job): @@ -2961,6 +3103,80 @@ class JobGCPFunctions(Job): '_aapi_repr_': 'Get Logs'}) +@attrs.define +class JobAtlassianBitbucket(Job): + + _type: str = attrs.field(init=False, default='Job:Atlassian Bitbucket', metadata={ + '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Atlassian Bitbucket'}) + 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'}) + pull_request_action: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pull Request Action'}) + pull_request_pipeline: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pull Request Pipeline'}) + workspace: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Workspace'}) + repo_slug: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Repo Slug'}) + type_attribute: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Type Attribute'}) + source: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Source'}) + destination: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Destination'}) + destination_commit_hash: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Destination Commit Hash'}) + pull_request_id: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pull Request ID'}) + ref_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Ref Type'}) + ref_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Ref Name'}) + commit: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Commit'}) + hash: str = attrs.field(kw_only=True, default=None, + metadata={'_aapi_repr_': 'Hash'}) + commit_hash: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Commit Hash'}) + selector: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Selector'}) + selector_type: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Selector Type'}) + pattern: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pattern'}) + variables: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Variables'}) + get_pipeline_steps_log: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Get Pipeline Steps Log'}) + title: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Title'}) + repository_full_name: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Repository Full Name'}) + pull_request_source: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pull Request Source'}) + pull_request_destination: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Pull Request Destination'}) + reviewers: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Reviewers'}) + message: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Message'}) + close_source_branch: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Close Source Branch'}) + merge_strategy: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Merge Strategy'}) + url_path: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'URL Path'}) + manual_json: str = attrs.field(kw_only=True, default=None, metadata={ + '_aapi_repr_': 'Manual JSON'}) + 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 JobAzureLogicApps(Job): @@ -3021,32 +3237,6 @@ class JobOCIVM(Job): '_aapi_repr_': 'Failure Tolerance'}) -@attrs.define -class JobAwsDataPipeline(Job): - - _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'}) - 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={ - '_aapi_repr_': 'Failure Tolerance'}) - - @attrs.define class JobOCIDataIntegration(Job): @@ -3073,6 +3263,32 @@ class JobOCIDataIntegration(Job): '_aapi_repr_': 'Failure Tolerance'}) +@attrs.define +class JobAwsDataPipeline(Job): + + _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'}) + 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={ + '_aapi_repr_': 'Failure Tolerance'}) + + @attrs.define class JobGCPCloudRun(Job): diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py index 25cf6b9..1bb0f75 100644 --- a/src/ctm_python_client/__init__.py +++ b/src/ctm_python_client/__init__.py @@ -1,2 +1,2 @@ -__version__ = '2.5.4' +__version__ = '2.5.5' __author__ = 'BMC Software' diff --git a/src/ctm_python_client/ext/autogen.py b/src/ctm_python_client/ext/autogen.py index 166cb3e..dc8cb8e 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 = ['ZDX112021', 'RST062023', 'AMW112024', 'ADP122022', 'TAB072023', 'AHD062022', 'ABK042023', 'DSL122024', 'ZVM062022', 'BEC032025', 'ZWB072025', 'AMM082023', 'GLU062021', 'TDO042024', 'ALM012024', 'PDY092024', 'GDP042022', 'ZFN032022', 'AWX122024', 'GVA092025', 'ACS042023', 'SBT032025', 'MFL022023', 'TER102023', 'ADB112022', 'MBI042022', 'ADF062021', 'GWF092023', 'ASQ032024', 'AAR072022', 'UIP072021', 'ZRM082023', 'SNF092022', 'ZLA112022', 'AQS012023', 'ATR122022', 'PBI082024', 'GFU012023', 'TDM052022', 'ABY122023', 'ARS112024', 'NFI042024', 'ASM0220223', 'OVM012024', 'SOP072023', 'DTG052025', 'VBR062025', 'GDF032022', 'GEA072025', 'ICS032022', 'RBK072025', 'ADY122023', 'BAK092023', 'ZBA042022', 'QLC092022', 'CMR022024', 'APP022025', 'GDU102023', 'VNB032025', 'ODI032024', 'AAF112024', 'ZSY062022', 'SFI122022', 'CCI012025', 'ADS102024', 'DBT042023', 'RMQ082024', 'ANS032024', 'ACF082023', 'AEC082022', 'GBA032023', 'DSW122024', 'MFW022023', 'BOO032022', 'DBX032022', 'GDR052023', 'DTG022025', 'AST072024', 'NBU032025', 'GVM062022', 'JEN022024', 'ADO112023', 'AAT052023', 'ABA092022', 'AEM072022', 'GCC052024', 'ASF012023', 'VMW102024', 'GBQ102022', 'GDM082023', 'KBN062023', 'FVT032025', 'ODF0420241', 'GDQ112023', 'GCR042024', 'AAP092024', 'ADM062025', 'ZML022023', 'ODS052024', 'ASB012025', 'COM032023'] +IF_PLUGINS = ['ABR092025', 'ZWB072025', 'ASM0220223', 'ZLA112022', 'ABK042023', 'ZBA042022', 'ODS052024', 'ALM012024', 'JEN022024', 'AAP092024', 'ADM062025', 'ADB112022', 'ANS032024', 'AAR072022', 'GDM082023', 'TAB072023', 'ADY122023', 'DTG022025', 'TER102023', 'PBI082024', 'COM032023', 'GDF032022', 'PDY092024', 'ADS102024', 'RST062023', 'ABA092022', 'BAK092023', 'ABB092025', 'NBU032025', 'MBI042022', 'ZML022023', 'ADF062021', 'MFB062025', 'ABY122023', 'ACF082023', 'SBT032025', 'BOO032022', 'DTG052025', 'RMQ082024', 'VMW102024', 'AEC082022', 'MFL022023', 'AAT052023', 'GDQ112023', 'ODI032024', 'TDM052022', 'ARS112024', 'DBX032022', 'AST072024', 'MFW022023', 'AMM082023', 'AWX122024', 'CMR022024', 'GLU062021', 'SNF092022', 'AAF112024', 'VNB032025', 'ZRM082023', 'FVT032025', 'ATR122022', 'BEC032025', 'GEA072025', 'AHD062022', 'VBR062025', 'GVM062022', 'ADP122022', 'GDU102023', 'ASQ032024', 'ODF0420241', 'GCC052024', 'GWF092023', 'AQS012023', 'CCI012025', 'UIP072021', 'GBQ102022', 'GDP042022', 'AMW112024', 'APP022025', 'SFI122022', 'DSW122024', 'NFI042024', 'GDR052023', 'ADO112023', 'AEM072022', 'TDO042024', 'GCR042024', 'ZFN032022', 'SOP072023', 'GBA032023', 'GVA092025', 'QLC092022', 'ZSY062022', 'ICS032022', 'DBT042023', 'GIT092025', 'MAT022025', 'ZDX112021', 'ZVM062022', 'ACS042023', 'DSL122024', 'ASB012025', 'KBN062023', 'GFU012023', 'OVM012024', 'RBK072025', 'ASF012023'] imports_str = '''from aapi import * diff --git a/tests/test_sanity.py b/tests/test_sanity.py index 6746012..6d1b035 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.5.4' + assert ctm_python_client.__version__ == '2.5.5'