diff --git a/tests/unit/gateway/test_choreographer_qa.py b/tests/unit/gateway/test_choreographer_qa.py index 7f731c29..508bc3a5 100644 --- a/tests/unit/gateway/test_choreographer_qa.py +++ b/tests/unit/gateway/test_choreographer_qa.py @@ -83,6 +83,7 @@ async def test_claim_review_returns_evidence_inline() -> None: work_svc = AsyncMock() git_svc = AsyncMock() git_svc.diff_and_files.return_value = ("+++ diff content", ["README.md"]) + _stub_empty_ledger(task_svc.session) deps = _make_deps(task=task_svc, work_session=work_svc, git=git_svc) c = Choreographer(deps) @@ -149,6 +150,7 @@ async def test_claim_review_marks_evidence_inspected() -> None: task_svc.qa_claim.return_value = t_claimed git_svc = AsyncMock() git_svc.diff_and_files.return_value = ("", []) + _stub_empty_ledger(task_svc.session) deps = _make_deps(task=task_svc, git=git_svc) c = Choreographer(deps) @@ -218,6 +220,7 @@ async def test_claim_review_returns_gateway_timeout_on_slow_evidence( return "+++ diff content", ["README.md"] git_svc.diff_and_files.side_effect = _slow_diff_and_files + _stub_empty_ledger(task_svc.session) deps = _make_deps(task=task_svc, work_session=work_svc, git=git_svc) c = Choreographer(deps) diff --git a/tests/unit/gateway/test_content_actions.py b/tests/unit/gateway/test_content_actions.py index 96108e40..3c803709 100644 --- a/tests/unit/gateway/test_content_actions.py +++ b/tests/unit/gateway/test_content_actions.py @@ -58,6 +58,17 @@ def _make_deps(**overrides: AsyncMock) -> ContentActionsDeps: ) +def _stub_empty_ledger(session: MagicMock) -> None: + """Configure a mock session's ``execute`` so ``ReviewFindingsRepository`` + finds no rows — covers evidence()'s findings-ledger read, which a bare + ``AsyncMock`` session doesn't configure and leaves unawaited coroutines.""" + session.execute = AsyncMock( + return_value=MagicMock( + scalars=MagicMock(return_value=MagicMock(all=MagicMock(return_value=[]))) + ) + ) + + # --------------------------------------------------------------------------- # commit # --------------------------------------------------------------------------- @@ -647,6 +658,7 @@ async def test_evidence_valid_task_returns_ok_with_pr_diff() -> None: ) task_svc = AsyncMock() task_svc.get.return_value = task_obj + _stub_empty_ledger(task_svc.session) git_svc = AsyncMock() git_svc.diff_and_files.return_value = ( "diff --git a/foo.py b/foo.py\n+added line", @@ -711,6 +723,7 @@ async def test_evidence_returns_gateway_timeout_on_slow_git( ) task_svc = AsyncMock() task_svc.get.return_value = task_obj + _stub_empty_ledger(task_svc.session) async def _slow_diff_and_files(**_kwargs: object) -> tuple[str, list[str]]: await asyncio.sleep(1) @@ -755,6 +768,7 @@ async def test_evidence_returns_gateway_timeout_on_slow_db_read( ) task_svc = AsyncMock() task_svc.get.return_value = task_obj + _stub_empty_ledger(task_svc.session) git_svc = AsyncMock() git_svc.diff_and_files.return_value = ("diff", ["f.py"]) workspace_svc = AsyncMock()