bingshuo/guanghu-ice-heart
Watch
1
0
Fork
You've already forked guanghu-ice-heart
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity

test(pool): isolate scheduler pending and active fixtures

Browse source
This commit is contained in:
冰朔 2026-09-11 17:27:08 +08:00
commit d4cb582e45
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
server-tools/persona-compute-pool/test_scheduler.py
View file

@ -9,8 +9,12 @@ class SchedulerTests(unittest.TestCase):
def test_audit_excludes_mother_node(self):
value=M.audit(); self.assertEqual(value["outcome"],"PASS"); self.assertTrue(value["mother_node_excluded"])
def test_pending_workers_do_not_fake_a_lease(self):
value=M.select({"min_cpu_cores":1,"min_memory_mb":256}); self.assertEqual(value["outcome"],"NO_ELIGIBLE_WORKER")
pool=M.load_map()
for node in pool["nodes"]: node["state"]="DISCOVERED_OPT_IN_PENDING_AGENT"
value=M.select({"min_cpu_cores":1,"min_memory_mb":256},pool); self.assertEqual(value["outcome"],"NO_ELIGIBLE_WORKER")
def test_active_worker_is_selected_by_capacity(self):
pool=M.load_map(); pool["nodes"][2]["state"]="ACTIVE_WORKER"; value=M.select({"min_cpu_cores":2,"min_memory_mb":1000},pool); self.assertEqual(value["outcome"],"LEASE_REQUESTED"); self.assertEqual(value["node_id"],"XX-GZ-001")
pool=M.load_map()
for node in pool["nodes"]: node["state"]="DISCOVERED_OPT_IN_PENDING_AGENT"
pool["nodes"][2]["state"]="ACTIVE_WORKER"; value=M.select({"min_cpu_cores":2,"min_memory_mb":1000},pool); self.assertEqual(value["outcome"],"LEASE_REQUESTED"); self.assertEqual(value["node_id"],"XX-GZ-001")
if __name__=="__main__": unittest.main()