This is an automated email from the ASF dual-hosted git repository.
arm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tooling-trusted-releases.git
The following commit(s) were added to refs/heads/main by this push:
new bdb490c9 Stub out methods used to check check messages
bdb490c9 is described below
commit bdb490c9adab90656b273b72bf23a6cfa37ca3e6
Author: Alastair McFarlane <[email protected]>
AuthorDate: Mon Feb 16 14:03:40 2026 +0000
Stub out methods used to check check messages
---
tests/unit/recorders.py | 21 +++++++++++++++++++++
1 file changed, 21 insertions(+)
diff --git a/tests/unit/recorders.py b/tests/unit/recorders.py
index b4633f5e..bdb20dcf 100644
--- a/tests/unit/recorders.py
+++ b/tests/unit/recorders.py
@@ -18,6 +18,7 @@
import datetime
import pathlib
from collections.abc import Awaitable, Callable
+from typing import Any
import atr.models.sql as sql
import atr.tasks.checks as checks
@@ -71,6 +72,26 @@ class RecorderStub(checks.Recorder):
inputs_hash=None,
)
+ async def exception(
+ self, message: str, data: Any, primary_rel_path: str | None = None,
member_rel_path: str | None = None
+ ) -> sql.CheckResult:
+ return await self._add(sql.CheckResultStatus.EXCEPTION, message, data,
primary_rel_path, member_rel_path)
+
+ async def failure(
+ self, message: str, data: Any, primary_rel_path: str | None = None,
member_rel_path: str | None = None
+ ) -> sql.CheckResult:
+ return await self._add(sql.CheckResultStatus.FAILURE, message, data,
primary_rel_path, member_rel_path)
+
+ async def success(
+ self, message: str, data: Any, primary_rel_path: str | None = None,
member_rel_path: str | None = None
+ ) -> sql.CheckResult:
+ return await self._add(sql.CheckResultStatus.SUCCESS, message, data,
primary_rel_path, member_rel_path)
+
+ async def warning(
+ self, message: str, data: Any, primary_rel_path: str | None = None,
member_rel_path: str | None = None
+ ) -> sql.CheckResult:
+ return await self._add(sql.CheckResultStatus.WARNING, message, data,
primary_rel_path, member_rel_path)
+
def get_recorder(recorder: checks.Recorder) -> Callable[[],
Awaitable[checks.Recorder]]:
async def _recorder() -> checks.Recorder:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
