mirror of
https://github.com/hanzoai/datastore.git
synced 2026-09-26 13:55:07 +00:00
zooqueen
9b59b8e388
Complete the filename-level debrand the 26.6 merge surfaced: 238 files (test .sql/.reference pairs, ci/jobs + workflows, utils, docs, package specs) renamed clickhouse->datastore (all case variants incl clickHouse), with references updated. Build-critical product files were already done. Excludes contrib (third-party).
78 lines
2.9 KiB
Python
78 lines
2.9 KiB
Python
"""
|
|
Unit tests for `FTResultsProcessor`, the job-side parser that turns
|
|
`datastore-test` output + its exit code into the report tree.
|
|
|
|
Focus: a run stopped early by `--max-failures` / `--max-failures-chain`
|
|
(exit code `MAX_FAILURES_EXIT_CODE`) must be reported as real failures plus a
|
|
"Too many test failures" leaf - NOT as "Server died" with the per-test
|
|
attribution demoted to UNKNOWN (which is what the aborted-run exit codes do).
|
|
"""
|
|
|
|
import os
|
|
import sys
|
|
|
|
# Repo root so `ci.*` resolves; the `ci` dir so the bare `from praktika...`
|
|
# import inside `functional_tests_results` resolves the same way it does when
|
|
# the praktika job runner imports it.
|
|
sys.path.insert(0, os.path.join(os.path.dirname(__file__), "../.."))
|
|
sys.path.insert(0, os.path.join(os.path.dirname(__file__), ".."))
|
|
|
|
from ci.jobs.scripts.functional_tests_results import (
|
|
MAX_FAILURES_EXIT_CODE,
|
|
STOP_TESTING_EXIT_CODE,
|
|
FTResultsProcessor,
|
|
)
|
|
from ci.praktika.result import Result
|
|
|
|
# Two real failures from a parallel run that stopped early. No "All tests have
|
|
# finished" line, because the run was aborted before completing.
|
|
_TWO_FAILURES = (
|
|
"00001_first_failing_test: [ FAIL ] 1.23 sec.\n"
|
|
"some failure details\n"
|
|
"00002_second_failing_test: [ FAIL ] 0.50 sec.\n"
|
|
"more failure details\n"
|
|
)
|
|
|
|
|
|
def _process(tmp_path, output, runner_exit_code):
|
|
(tmp_path / "test_result.txt").write_text(output, encoding="utf-8")
|
|
return FTResultsProcessor(wd=str(tmp_path)).run(runner_exit_code=runner_exit_code)
|
|
|
|
|
|
def _named(result, name):
|
|
return [r for r in result.results if r.name == name]
|
|
|
|
|
|
def test_max_failures_keeps_real_failures_and_adds_summary(tmp_path):
|
|
result = _process(tmp_path, _TWO_FAILURES, MAX_FAILURES_EXIT_CODE)
|
|
|
|
assert result.status == Result.Status.FAIL
|
|
|
|
# The informational leaf is present...
|
|
summary = _named(result, "Too many test failures")
|
|
assert len(summary) == 1
|
|
assert summary[0].status == Result.Status.FAIL
|
|
|
|
# ...no synthetic "Server died" leaf is added...
|
|
assert not _named(result, "Server died")
|
|
|
|
# ...and both real failures stay FAIL (not demoted to UNKNOWN).
|
|
for name in ("00001_first_failing_test", "00002_second_failing_test"):
|
|
entries = _named(result, name)
|
|
assert len(entries) == 1, name
|
|
assert entries[0].status == Result.Status.FAIL, name
|
|
|
|
|
|
def test_aborted_run_still_reports_server_died(tmp_path):
|
|
"""Contrast: the same output with an aborted-run exit code keeps the old
|
|
behavior - "Server died" plus the failures demoted to UNKNOWN."""
|
|
result = _process(tmp_path, _TWO_FAILURES, STOP_TESTING_EXIT_CODE)
|
|
|
|
assert result.status == Result.Status.FAIL
|
|
assert len(_named(result, "Server died")) == 1
|
|
assert not _named(result, "Too many test failures")
|
|
for name in ("00001_first_failing_test", "00002_second_failing_test"):
|
|
entries = _named(result, name)
|
|
assert len(entries) == 1, name
|
|
assert entries[0].status == Result.Status.UNKNOWN, name
|