Skip to content

Commit

Permalink
Version name update to 1.0.0.
Browse files Browse the repository at this point in the history
  • Loading branch information
piotrczarnas committed Jan 21, 2024
1 parent 5178642 commit 84b852e
Show file tree
Hide file tree
Showing 148 changed files with 6,154 additions and 18,947 deletions.
4 changes: 3 additions & 1 deletion CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# 0.5.0
# 1.0.0
* Apache Spark connector
* Databricks connector
* Initial versions of Apache Trino and Presto connectors
Expand All @@ -7,3 +7,5 @@
* Fixes in the UI - table status overview screen, filtering checks related to incidents
* Support activating and deactivating multiple data quality checks from UI
* Additional navigation screens for jumping between schemas and tables
* COMPLETE DOCUMENTATION with examples

2 changes: 1 addition & 1 deletion VERSION
Original file line number Diff line number Diff line change
@@ -1 +1 @@
0.4.1
1.0.0
2 changes: 1 addition & 1 deletion distribution/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@

<groupId>com.dqops</groupId>
<artifactId>dqo-distribution</artifactId>
<version>0.4.1</version> <!-- DQOps Version, do not touch (changed automatically) -->
<version>1.0.0</version> <!-- DQOps Version, do not touch (changed automatically) -->
<name>dqo-distribution</name>
<description>DQOps Data Quality Operations Center final assembly</description>
<packaging>pom</packaging>
Expand Down
79 changes: 8 additions & 71 deletions distribution/python/dqops/client/api/checks/create_check.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
from ... import errors
from ...client import AuthenticatedClient, Client
from ...models.check_definition_model import CheckDefinitionModel
from ...models.mono_void import MonoVoid
from ...types import Response


Expand All @@ -30,11 +29,9 @@ def _get_kwargs(

def _parse_response(
*, client: Union[AuthenticatedClient, Client], response: httpx.Response
) -> Optional[MonoVoid]:
if response.status_code == HTTPStatus.OK:
response_200 = MonoVoid.from_dict(response.json())

return response_200
) -> Optional[Any]:
if response.status_code == HTTPStatus.CREATED:
return None
if client.raise_on_unexpected_status:
raise errors.UnexpectedStatus(response.status_code, response.content)
else:
Expand All @@ -43,7 +40,7 @@ def _parse_response(

def _build_response(
*, client: Union[AuthenticatedClient, Client], response: httpx.Response
) -> Response[MonoVoid]:
) -> Response[Any]:
return Response(
status_code=HTTPStatus(response.status_code),
content=response.content,
Expand All @@ -57,7 +54,7 @@ def sync_detailed(
*,
client: AuthenticatedClient,
json_body: CheckDefinitionModel,
) -> Response[MonoVoid]:
) -> Response[Any]:
"""createCheck
Creates (adds) a new custom check that is a pair of a sensor name and a rule name.
Expand All @@ -71,7 +68,7 @@ def sync_detailed(
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
Response[MonoVoid]
Response[Any]
"""

kwargs = _get_kwargs(
Expand All @@ -86,41 +83,12 @@ def sync_detailed(
return _build_response(client=client, response=response)


def sync(
full_check_name: str,
*,
client: AuthenticatedClient,
json_body: CheckDefinitionModel,
) -> Optional[MonoVoid]:
"""createCheck
Creates (adds) a new custom check that is a pair of a sensor name and a rule name.
Args:
full_check_name (str):
json_body (CheckDefinitionModel): Data quality check definition model
Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
MonoVoid
"""

return sync_detailed(
full_check_name=full_check_name,
client=client,
json_body=json_body,
).parsed


async def asyncio_detailed(
full_check_name: str,
*,
client: AuthenticatedClient,
json_body: CheckDefinitionModel,
) -> Response[MonoVoid]:
) -> Response[Any]:
"""createCheck
Creates (adds) a new custom check that is a pair of a sensor name and a rule name.
Expand All @@ -134,7 +102,7 @@ async def asyncio_detailed(
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
Response[MonoVoid]
Response[Any]
"""

kwargs = _get_kwargs(
Expand All @@ -145,34 +113,3 @@ async def asyncio_detailed(
response = await client.get_async_httpx_client().request(**kwargs)

return _build_response(client=client, response=response)


async def asyncio(
full_check_name: str,
*,
client: AuthenticatedClient,
json_body: CheckDefinitionModel,
) -> Optional[MonoVoid]:
"""createCheck
Creates (adds) a new custom check that is a pair of a sensor name and a rule name.
Args:
full_check_name (str):
json_body (CheckDefinitionModel): Data quality check definition model
Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
MonoVoid
"""

return (
await asyncio_detailed(
full_check_name=full_check_name,
client=client,
json_body=json_body,
)
).parsed
73 changes: 8 additions & 65 deletions distribution/python/dqops/client/api/checks/delete_check.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@

from ... import errors
from ...client import AuthenticatedClient, Client
from ...models.mono_void import MonoVoid
from ...types import Response


Expand All @@ -24,11 +23,9 @@ def _get_kwargs(

def _parse_response(
*, client: Union[AuthenticatedClient, Client], response: httpx.Response
) -> Optional[MonoVoid]:
if response.status_code == HTTPStatus.OK:
response_200 = MonoVoid.from_dict(response.json())

return response_200
) -> Optional[Any]:
if response.status_code == HTTPStatus.NOT_FOUND:
return None
if client.raise_on_unexpected_status:
raise errors.UnexpectedStatus(response.status_code, response.content)
else:
Expand All @@ -37,7 +34,7 @@ def _parse_response(

def _build_response(
*, client: Union[AuthenticatedClient, Client], response: httpx.Response
) -> Response[MonoVoid]:
) -> Response[Any]:
return Response(
status_code=HTTPStatus(response.status_code),
content=response.content,
Expand All @@ -50,7 +47,7 @@ def sync_detailed(
full_check_name: str,
*,
client: AuthenticatedClient,
) -> Response[MonoVoid]:
) -> Response[Any]:
"""deleteCheck
Deletes a custom check definition
Expand All @@ -63,7 +60,7 @@ def sync_detailed(
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
Response[MonoVoid]
Response[Any]
"""

kwargs = _get_kwargs(
Expand All @@ -77,37 +74,11 @@ def sync_detailed(
return _build_response(client=client, response=response)


def sync(
full_check_name: str,
*,
client: AuthenticatedClient,
) -> Optional[MonoVoid]:
"""deleteCheck
Deletes a custom check definition
Args:
full_check_name (str):
Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
MonoVoid
"""

return sync_detailed(
full_check_name=full_check_name,
client=client,
).parsed


async def asyncio_detailed(
full_check_name: str,
*,
client: AuthenticatedClient,
) -> Response[MonoVoid]:
) -> Response[Any]:
"""deleteCheck
Deletes a custom check definition
Expand All @@ -120,7 +91,7 @@ async def asyncio_detailed(
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
Response[MonoVoid]
Response[Any]
"""

kwargs = _get_kwargs(
Expand All @@ -130,31 +101,3 @@ async def asyncio_detailed(
response = await client.get_async_httpx_client().request(**kwargs)

return _build_response(client=client, response=response)


async def asyncio(
full_check_name: str,
*,
client: AuthenticatedClient,
) -> Optional[MonoVoid]:
"""deleteCheck
Deletes a custom check definition
Args:
full_check_name (str):
Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.
Returns:
MonoVoid
"""

return (
await asyncio_detailed(
full_check_name=full_check_name,
client=client,
)
).parsed
Loading

0 comments on commit 84b852e

Please sign in to comment.