auto-sync: 2026-06-02 07:49:40
This commit is contained in:
@@ -402,7 +402,7 @@ class TestE5ParentAggregation:
|
||||
finally:
|
||||
conn.close()
|
||||
# _refresh_parent_statuses 应跳过 cancelled 父任务
|
||||
ticker = Ticker.__new__(Ticker)
|
||||
ticker = Ticker(registry=MagicMock())
|
||||
ticker._refresh_parent_statuses(self.db_path)
|
||||
# 验证父任务仍是 cancelled
|
||||
t = self.bb.get_task(self.parent_id)
|
||||
@@ -433,7 +433,7 @@ class TestE6DependencyChain:
|
||||
for s in ["claimed", "working", "review", "done"]:
|
||||
self.bb.update_task_status("dep-a", s, agent="test")
|
||||
# 手动 tick 依赖推进
|
||||
ticker = Ticker.__new__(Ticker)
|
||||
ticker = Ticker(registry=MagicMock())
|
||||
advanced = ticker._advance_dependencies(self.db_path)
|
||||
assert "dep-b" in advanced
|
||||
t = self.bb.get_task("dep-b")
|
||||
@@ -443,7 +443,7 @@ class TestE6DependencyChain:
|
||||
"""A 未完成 → B 保持 blocked"""
|
||||
self.bb.create_task(Task(id="dep-c", title="C", status="pending"))
|
||||
self.bb.create_task(Task(id="dep-d", title="D", status="blocked", depends_on=json.dumps(["dep-c"])))
|
||||
ticker = Ticker.__new__(Ticker)
|
||||
ticker = Ticker(registry=MagicMock())
|
||||
advanced = ticker._advance_dependencies(self.db_path)
|
||||
assert "dep-d" not in advanced
|
||||
assert self.bb.get_task("dep-d").status == "blocked"
|
||||
@@ -456,7 +456,7 @@ class TestE6DependencyChain:
|
||||
# 完成 A
|
||||
for s in ["claimed", "working", "review", "done"]:
|
||||
self.bb.update_task_status("chain-a", s, agent="test")
|
||||
ticker = Ticker.__new__(Ticker)
|
||||
ticker = Ticker(registry=MagicMock())
|
||||
advanced1 = ticker._advance_dependencies(self.db_path)
|
||||
assert "chain-b" in advanced1
|
||||
# B 现在 pending,完成 B
|
||||
@@ -497,7 +497,7 @@ class TestE7Timeout:
|
||||
finally:
|
||||
conn.close()
|
||||
|
||||
ticker = Ticker.__new__(Ticker)
|
||||
ticker = Ticker(registry=MagicMock())
|
||||
ticker.claim_timeout_minutes = 5.0
|
||||
ticker.default_task_timeout_minutes = 30.0
|
||||
reclaimed = ticker._check_timeouts(self.db_path)
|
||||
@@ -520,7 +520,7 @@ class TestE7Timeout:
|
||||
finally:
|
||||
conn.close()
|
||||
|
||||
ticker = Ticker.__new__(Ticker)
|
||||
ticker = Ticker(registry=MagicMock())
|
||||
ticker.claim_timeout_minutes = 5.0
|
||||
ticker.default_task_timeout_minutes = 30.0
|
||||
reclaimed = ticker._check_timeouts(self.db_path)
|
||||
|
||||
Reference in New Issue
Block a user