Skip to content

Commit

Permalink
test_report: Use module-level tests and fixtures
Browse files Browse the repository at this point in the history
Signed-off-by: Zack Cerza <[email protected]>
  • Loading branch information
zmc committed Jul 11, 2024
1 parent 182c065 commit b38bb95
Showing 1 changed file with 68 additions and 67 deletions.
135 changes: 68 additions & 67 deletions teuthology/test/test_report.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,80 +6,81 @@
from teuthology import report


@pytest.fixture(autouse=True)
@pytest.fixture
def archive(tmp_path):
return fake_archive.FakeArchive(archive_base=str(tmp_path))


class TestSerializer(object):
@pytest.fixture(autouse=True)
def setup_method(self, archive):
self.archive = archive
self.archive.setup()
self.archive_base = self.archive.archive_base
self.reporter = report.ResultsReporter(archive_base=self.archive_base)
archive = fake_archive.FakeArchive(archive_base=str(tmp_path))
yield archive
archive.teardown()

def teardown_method(self):
self.archive.teardown()

def test_all_runs_one_run(self):
run_name = "test_all_runs"
yaml_path = "examples/3node_ceph.yaml"
job_count = 3
self.archive.create_fake_run(run_name, job_count, yaml_path)
assert [run_name] == self.reporter.serializer.all_runs

def test_all_runs_three_runs(self):
run_count = 3
runs = {}
for i in range(run_count):
run_name = "run #%s" % i
yaml_path = "examples/3node_ceph.yaml"
job_count = 3
job_ids = self.archive.create_fake_run(
run_name,
job_count,
yaml_path)
runs[run_name] = job_ids
assert sorted(runs.keys()) == sorted(self.reporter.serializer.all_runs)

def test_jobs_for_run(self):
run_name = "test_jobs_for_run"
yaml_path = "examples/3node_ceph.yaml"
job_count = 3
jobs = self.archive.create_fake_run(run_name, job_count, yaml_path)
job_ids = [str(job['job_id']) for job in jobs]
@pytest.fixture(autouse=True)
def reporter(archive):
archive.setup()
return report.ResultsReporter(archive_base=archive.archive_base)

got_jobs = self.reporter.serializer.jobs_for_run(run_name)
assert sorted(job_ids) == sorted(got_jobs.keys())

def test_running_jobs_for_run(self):
run_name = "test_jobs_for_run"
yaml_path = "examples/3node_ceph.yaml"
job_count = 10
num_hung = 3
self.archive.create_fake_run(run_name, job_count, yaml_path,
num_hung=num_hung)
def test_all_runs_one_run(archive, reporter):
run_name = "test_all_runs"
yaml_path = "examples/3node_ceph.yaml"
job_count = 3
archive.create_fake_run(run_name, job_count, yaml_path)
assert [run_name] == reporter.serializer.all_runs

got_jobs = self.reporter.serializer.running_jobs_for_run(run_name)
assert len(got_jobs) == num_hung

def test_json_for_job(self):
run_name = "test_json_for_job"
def test_all_runs_three_runs(archive, reporter):
run_count = 3
runs = {}
for i in range(run_count):
run_name = "run #%s" % i
yaml_path = "examples/3node_ceph.yaml"
job_count = 1
jobs = self.archive.create_fake_run(run_name, job_count, yaml_path)
job = jobs[0]

with open(yaml_path) as yaml_file:
obj_from_yaml = yaml.safe_load(yaml_file)
full_obj = obj_from_yaml.copy()
full_obj.update(job['info'])
full_obj.update(job['summary'])

out_json = self.reporter.serializer.json_for_job(
run_name, str(job['job_id']))
out_obj = json.loads(out_json)
assert full_obj == out_obj
job_count = 3
job_ids = archive.create_fake_run(
run_name,
job_count,
yaml_path)
runs[run_name] = job_ids
assert sorted(runs.keys()) == sorted(reporter.serializer.all_runs)


def test_jobs_for_run(archive, reporter):
run_name = "test_jobs_for_run"
yaml_path = "examples/3node_ceph.yaml"
job_count = 3
jobs = archive.create_fake_run(run_name, job_count, yaml_path)
job_ids = [str(job['job_id']) for job in jobs]

got_jobs = reporter.serializer.jobs_for_run(run_name)
assert sorted(job_ids) == sorted(got_jobs.keys())


def test_running_jobs_for_run(archive, reporter):
run_name = "test_jobs_for_run"
yaml_path = "examples/3node_ceph.yaml"
job_count = 10
num_hung = 3
archive.create_fake_run(run_name, job_count, yaml_path,
num_hung=num_hung)

got_jobs = reporter.serializer.running_jobs_for_run(run_name)
assert len(got_jobs) == num_hung


def test_json_for_job(archive, reporter):
run_name = "test_json_for_job"
yaml_path = "examples/3node_ceph.yaml"
job_count = 1
jobs = archive.create_fake_run(run_name, job_count, yaml_path)
job = jobs[0]

with open(yaml_path) as yaml_file:
obj_from_yaml = yaml.safe_load(yaml_file)
full_obj = obj_from_yaml.copy()
full_obj.update(job['info'])
full_obj.update(job['summary'])

out_json = reporter.serializer.json_for_job(
run_name, str(job['job_id']))
out_obj = json.loads(out_json)
assert full_obj == out_obj


0 comments on commit b38bb95

Please sign in to comment.