Skip to content

Commit a5dac4e

Browse files
committed
Documentation and the python client updated after teradata connector was added.
1 parent 5673647 commit a5dac4e

File tree

203 files changed

+62719
-5841
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

203 files changed

+62719
-5841
lines changed

distribution/python/dqops/client/models/__init__.py

+4
Original file line numberDiff line numberDiff line change
@@ -2105,6 +2105,8 @@
21052105
from .target_rule_severity_level import TargetRuleSeverityLevel
21062106
from .target_table_pattern_spec import TargetTablePatternSpec
21072107
from .temporal_unit import TemporalUnit
2108+
from .teradata_parameters_spec import TeradataParametersSpec
2109+
from .teradata_parameters_spec_properties import TeradataParametersSpecProperties
21082110
from .text_built_in_date_formats import TextBuiltInDateFormats
21092111
from .time_period_gradient import TimePeriodGradient
21102112
from .time_window_filter_parameters import TimeWindowFilterParameters
@@ -3101,6 +3103,8 @@
31013103
"TargetRuleSeverityLevel",
31023104
"TargetTablePatternSpec",
31033105
"TemporalUnit",
3106+
"TeradataParametersSpec",
3107+
"TeradataParametersSpecProperties",
31043108
"TextBuiltInDateFormats",
31053109
"TimePeriodGradient",
31063110
"TimestampColumnsSpec",

distribution/python/dqops/client/models/connection_model.py

+18
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
from ..models.statistics_collector_search_filters import (
3434
StatisticsCollectorSearchFilters,
3535
)
36+
from ..models.teradata_parameters_spec import TeradataParametersSpec
3637
from ..models.trino_parameters_spec import TrinoParametersSpec
3738

3839

@@ -70,6 +71,7 @@ class ConnectionModel:
7071
mariadb (Union[Unset, MariaDbParametersSpec]):
7172
clickhouse (Union[Unset, ClickHouseParametersSpec]):
7273
questdb (Union[Unset, QuestDbParametersSpec]):
74+
teradata (Union[Unset, TeradataParametersSpec]):
7375
run_checks_job_template (Union[Unset, CheckSearchFilters]): Target data quality checks filter, identifies which
7476
checks on which tables and columns should be executed.
7577
run_profiling_checks_job_template (Union[Unset, CheckSearchFilters]): Target data quality checks filter,
@@ -115,6 +117,7 @@ class ConnectionModel:
115117
mariadb: Union[Unset, "MariaDbParametersSpec"] = UNSET
116118
clickhouse: Union[Unset, "ClickHouseParametersSpec"] = UNSET
117119
questdb: Union[Unset, "QuestDbParametersSpec"] = UNSET
120+
teradata: Union[Unset, "TeradataParametersSpec"] = UNSET
118121
run_checks_job_template: Union[Unset, "CheckSearchFilters"] = UNSET
119122
run_profiling_checks_job_template: Union[Unset, "CheckSearchFilters"] = UNSET
120123
run_monitoring_checks_job_template: Union[Unset, "CheckSearchFilters"] = UNSET
@@ -208,6 +211,10 @@ def to_dict(self) -> Dict[str, Any]:
208211
if not isinstance(self.questdb, Unset):
209212
questdb = self.questdb.to_dict()
210213

214+
teradata: Union[Unset, Dict[str, Any]] = UNSET
215+
if not isinstance(self.teradata, Unset):
216+
teradata = self.teradata.to_dict()
217+
211218
run_checks_job_template: Union[Unset, Dict[str, Any]] = UNSET
212219
if not isinstance(self.run_checks_job_template, Unset):
213220
run_checks_job_template = self.run_checks_job_template.to_dict()
@@ -297,6 +304,8 @@ def to_dict(self) -> Dict[str, Any]:
297304
field_dict["clickhouse"] = clickhouse
298305
if questdb is not UNSET:
299306
field_dict["questdb"] = questdb
307+
if teradata is not UNSET:
308+
field_dict["teradata"] = teradata
300309
if run_checks_job_template is not UNSET:
301310
field_dict["run_checks_job_template"] = run_checks_job_template
302311
if run_profiling_checks_job_template is not UNSET:
@@ -360,6 +369,7 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
360369
from ..models.statistics_collector_search_filters import (
361370
StatisticsCollectorSearchFilters,
362371
)
372+
from ..models.teradata_parameters_spec import TeradataParametersSpec
363373
from ..models.trino_parameters_spec import TrinoParametersSpec
364374

365375
d = src_dict.copy()
@@ -497,6 +507,13 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
497507
else:
498508
questdb = QuestDbParametersSpec.from_dict(_questdb)
499509

510+
_teradata = d.pop("teradata", UNSET)
511+
teradata: Union[Unset, TeradataParametersSpec]
512+
if isinstance(_teradata, Unset):
513+
teradata = UNSET
514+
else:
515+
teradata = TeradataParametersSpec.from_dict(_teradata)
516+
500517
_run_checks_job_template = d.pop("run_checks_job_template", UNSET)
501518
run_checks_job_template: Union[Unset, CheckSearchFilters]
502519
if isinstance(_run_checks_job_template, Unset):
@@ -603,6 +620,7 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
603620
mariadb=mariadb,
604621
clickhouse=clickhouse,
605622
questdb=questdb,
623+
teradata=teradata,
606624
run_checks_job_template=run_checks_job_template,
607625
run_profiling_checks_job_template=run_profiling_checks_job_template,
608626
run_monitoring_checks_job_template=run_monitoring_checks_job_template,

distribution/python/dqops/client/models/connection_spec.py

+18
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
from ..models.snowflake_parameters_spec import SnowflakeParametersSpec
3434
from ..models.spark_parameters_spec import SparkParametersSpec
3535
from ..models.sql_server_parameters_spec import SqlServerParametersSpec
36+
from ..models.teradata_parameters_spec import TeradataParametersSpec
3637
from ..models.trino_parameters_spec import TrinoParametersSpec
3738

3839

@@ -61,6 +62,7 @@ class ConnectionSpec:
6162
mariadb (Union[Unset, MariaDbParametersSpec]):
6263
clickhouse (Union[Unset, ClickHouseParametersSpec]):
6364
questdb (Union[Unset, QuestDbParametersSpec]):
65+
teradata (Union[Unset, TeradataParametersSpec]):
6466
parallel_jobs_limit (Union[Unset, int]): The concurrency limit for the maximum number of parallel SQL queries
6567
executed on this connection.
6668
default_grouping_configuration (Union[Unset, DataGroupingConfigurationSpec]):
@@ -98,6 +100,7 @@ class ConnectionSpec:
98100
mariadb: Union[Unset, "MariaDbParametersSpec"] = UNSET
99101
clickhouse: Union[Unset, "ClickHouseParametersSpec"] = UNSET
100102
questdb: Union[Unset, "QuestDbParametersSpec"] = UNSET
103+
teradata: Union[Unset, "TeradataParametersSpec"] = UNSET
101104
parallel_jobs_limit: Union[Unset, int] = UNSET
102105
default_grouping_configuration: Union[Unset, "DataGroupingConfigurationSpec"] = (
103106
UNSET
@@ -184,6 +187,10 @@ def to_dict(self) -> Dict[str, Any]:
184187
if not isinstance(self.questdb, Unset):
185188
questdb = self.questdb.to_dict()
186189

190+
teradata: Union[Unset, Dict[str, Any]] = UNSET
191+
if not isinstance(self.teradata, Unset):
192+
teradata = self.teradata.to_dict()
193+
187194
parallel_jobs_limit = self.parallel_jobs_limit
188195
default_grouping_configuration: Union[Unset, Dict[str, Any]] = UNSET
189196
if not isinstance(self.default_grouping_configuration, Unset):
@@ -259,6 +266,8 @@ def to_dict(self) -> Dict[str, Any]:
259266
field_dict["clickhouse"] = clickhouse
260267
if questdb is not UNSET:
261268
field_dict["questdb"] = questdb
269+
if teradata is not UNSET:
270+
field_dict["teradata"] = teradata
262271
if parallel_jobs_limit is not UNSET:
263272
field_dict["parallel_jobs_limit"] = parallel_jobs_limit
264273
if default_grouping_configuration is not UNSET:
@@ -312,6 +321,7 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
312321
from ..models.snowflake_parameters_spec import SnowflakeParametersSpec
313322
from ..models.spark_parameters_spec import SparkParametersSpec
314323
from ..models.sql_server_parameters_spec import SqlServerParametersSpec
324+
from ..models.teradata_parameters_spec import TeradataParametersSpec
315325
from ..models.trino_parameters_spec import TrinoParametersSpec
316326

317327
d = src_dict.copy()
@@ -441,6 +451,13 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
441451
else:
442452
questdb = QuestDbParametersSpec.from_dict(_questdb)
443453

454+
_teradata = d.pop("teradata", UNSET)
455+
teradata: Union[Unset, TeradataParametersSpec]
456+
if isinstance(_teradata, Unset):
457+
teradata = UNSET
458+
else:
459+
teradata = TeradataParametersSpec.from_dict(_teradata)
460+
444461
parallel_jobs_limit = d.pop("parallel_jobs_limit", UNSET)
445462

446463
_default_grouping_configuration = d.pop("default_grouping_configuration", UNSET)
@@ -514,6 +531,7 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
514531
mariadb=mariadb,
515532
clickhouse=clickhouse,
516533
questdb=questdb,
534+
teradata=teradata,
517535
parallel_jobs_limit=parallel_jobs_limit,
518536
default_grouping_configuration=default_grouping_configuration,
519537
schedules=schedules,

distribution/python/dqops/client/models/display_hint.py

+1
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33

44
class DisplayHint(str, Enum):
55
COLUMN_NAMES = "column_names"
6+
REQUIRES_PAID_VERSION = "requires_paid_version"
67
TEXTAREA = "textarea"
78

89
def __str__(self) -> str:

distribution/python/dqops/client/models/dqo_user_profile_model.py

+9
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,8 @@ class DqoUserProfileModel:
6262
ENTERPRISE license of DQOps.
6363
can_synchronize_to_data_catalog (Union[Unset, bool]): User can synchronize data to a data catalog. The instance
6464
must be configured correctly and the user must have at least an EDITOR role.
65+
can_use_ai_anomaly_detection (Union[Unset, bool]): The DQOps instance is a paid version with advanced AI anomaly
66+
prediction.
6567
"""
6668

6769
user: Union[Unset, str] = UNSET
@@ -95,6 +97,7 @@ class DqoUserProfileModel:
9597
can_change_own_password: Union[Unset, bool] = UNSET
9698
can_use_data_domains: Union[Unset, bool] = UNSET
9799
can_synchronize_to_data_catalog: Union[Unset, bool] = UNSET
100+
can_use_ai_anomaly_detection: Union[Unset, bool] = UNSET
98101
additional_properties: Dict[str, Any] = _attrs_field(init=False, factory=dict)
99102

100103
def to_dict(self) -> Dict[str, Any]:
@@ -134,6 +137,7 @@ def to_dict(self) -> Dict[str, Any]:
134137
can_change_own_password = self.can_change_own_password
135138
can_use_data_domains = self.can_use_data_domains
136139
can_synchronize_to_data_catalog = self.can_synchronize_to_data_catalog
140+
can_use_ai_anomaly_detection = self.can_use_ai_anomaly_detection
137141

138142
field_dict: Dict[str, Any] = {}
139143
field_dict.update(self.additional_properties)
@@ -206,6 +210,8 @@ def to_dict(self) -> Dict[str, Any]:
206210
field_dict["can_synchronize_to_data_catalog"] = (
207211
can_synchronize_to_data_catalog
208212
)
213+
if can_use_ai_anomaly_detection is not UNSET:
214+
field_dict["can_use_ai_anomaly_detection"] = can_use_ai_anomaly_detection
209215

210216
return field_dict
211217

@@ -285,6 +291,8 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
285291
"can_synchronize_to_data_catalog", UNSET
286292
)
287293

294+
can_use_ai_anomaly_detection = d.pop("can_use_ai_anomaly_detection", UNSET)
295+
288296
dqo_user_profile_model = cls(
289297
user=user,
290298
tenant=tenant,
@@ -317,6 +325,7 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
317325
can_change_own_password=can_change_own_password,
318326
can_use_data_domains=can_use_data_domains,
319327
can_synchronize_to_data_catalog=can_synchronize_to_data_catalog,
328+
can_use_ai_anomaly_detection=can_use_ai_anomaly_detection,
320329
)
321330

322331
dqo_user_profile_model.additional_properties = d

distribution/python/dqops/client/models/provider_type.py

+1
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ class ProviderType(str, Enum):
1818
SNOWFLAKE = "snowflake"
1919
SPARK = "spark"
2020
SQLSERVER = "sqlserver"
21+
TERADATA = "teradata"
2122
TRINO = "trino"
2223

2324
def __str__(self) -> str:
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,121 @@
1+
from typing import TYPE_CHECKING, Any, Dict, List, Type, TypeVar, Union
2+
3+
from attrs import define as _attrs_define
4+
from attrs import field as _attrs_field
5+
6+
from ..types import UNSET, Unset
7+
8+
if TYPE_CHECKING:
9+
from ..models.teradata_parameters_spec_properties import (
10+
TeradataParametersSpecProperties,
11+
)
12+
13+
14+
T = TypeVar("T", bound="TeradataParametersSpec")
15+
16+
17+
@_attrs_define
18+
class TeradataParametersSpec:
19+
"""
20+
Attributes:
21+
host (Union[Unset, str]): Teradata host name. Supports also a ${TERADATA_HOST} configuration with a custom
22+
environment variable.
23+
port (Union[Unset, str]): Teradata port number. The default port is 1025. Supports also a ${TERADATA_PORT}
24+
configuration with a custom environment variable.
25+
user (Union[Unset, str]): Teradata user name. The value can be in the ${ENVIRONMENT_VARIABLE_NAME} format to use
26+
dynamic substitution.
27+
password (Union[Unset, str]): Teradata database password. The value can be in the ${ENVIRONMENT_VARIABLE_NAME}
28+
format to use dynamic substitution.
29+
properties (Union[Unset, TeradataParametersSpecProperties]): A dictionary of custom JDBC parameters that are
30+
added to the JDBC connection string, a key/value dictionary.
31+
database (Union[Unset, str]):
32+
"""
33+
34+
host: Union[Unset, str] = UNSET
35+
port: Union[Unset, str] = UNSET
36+
user: Union[Unset, str] = UNSET
37+
password: Union[Unset, str] = UNSET
38+
properties: Union[Unset, "TeradataParametersSpecProperties"] = UNSET
39+
database: Union[Unset, str] = UNSET
40+
additional_properties: Dict[str, Any] = _attrs_field(init=False, factory=dict)
41+
42+
def to_dict(self) -> Dict[str, Any]:
43+
host = self.host
44+
port = self.port
45+
user = self.user
46+
password = self.password
47+
properties: Union[Unset, Dict[str, Any]] = UNSET
48+
if not isinstance(self.properties, Unset):
49+
properties = self.properties.to_dict()
50+
51+
database = self.database
52+
53+
field_dict: Dict[str, Any] = {}
54+
field_dict.update(self.additional_properties)
55+
field_dict.update({})
56+
if host is not UNSET:
57+
field_dict["host"] = host
58+
if port is not UNSET:
59+
field_dict["port"] = port
60+
if user is not UNSET:
61+
field_dict["user"] = user
62+
if password is not UNSET:
63+
field_dict["password"] = password
64+
if properties is not UNSET:
65+
field_dict["properties"] = properties
66+
if database is not UNSET:
67+
field_dict["database"] = database
68+
69+
return field_dict
70+
71+
@classmethod
72+
def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
73+
from ..models.teradata_parameters_spec_properties import (
74+
TeradataParametersSpecProperties,
75+
)
76+
77+
d = src_dict.copy()
78+
host = d.pop("host", UNSET)
79+
80+
port = d.pop("port", UNSET)
81+
82+
user = d.pop("user", UNSET)
83+
84+
password = d.pop("password", UNSET)
85+
86+
_properties = d.pop("properties", UNSET)
87+
properties: Union[Unset, TeradataParametersSpecProperties]
88+
if isinstance(_properties, Unset):
89+
properties = UNSET
90+
else:
91+
properties = TeradataParametersSpecProperties.from_dict(_properties)
92+
93+
database = d.pop("database", UNSET)
94+
95+
teradata_parameters_spec = cls(
96+
host=host,
97+
port=port,
98+
user=user,
99+
password=password,
100+
properties=properties,
101+
database=database,
102+
)
103+
104+
teradata_parameters_spec.additional_properties = d
105+
return teradata_parameters_spec
106+
107+
@property
108+
def additional_keys(self) -> List[str]:
109+
return list(self.additional_properties.keys())
110+
111+
def __getitem__(self, key: str) -> Any:
112+
return self.additional_properties[key]
113+
114+
def __setitem__(self, key: str, value: Any) -> None:
115+
self.additional_properties[key] = value
116+
117+
def __delitem__(self, key: str) -> None:
118+
del self.additional_properties[key]
119+
120+
def __contains__(self, key: str) -> bool:
121+
return key in self.additional_properties

0 commit comments

Comments
 (0)