test: prune low-signal assertions and tighten guards

Co-authored-by: Copilot App <[email protected]>

tests/integration/test_pipeline_flow.py

@@ -130,12 +130,10 @@ class TestPipelineSuccessFlow:
 
         services = _build_services(default_session_factory)
         queued_job = await services.jobs.read_job(job_id=upload_result.job_id, session=async_session)
-        processed = queued_job is not None
+        assert queued_job is not None
-        if queued_job is not None:
+        await advance_job(job=queued_job, services=services, settings=settings, session=async_session)
-            await advance_job(job=queued_job, services=services, settings=settings, session=async_session)
         job = await services.jobs.read_job(job_id=upload_result.job_id, session=async_session)
 
-        assert processed is True
         assert job is not None
         assert job.status == JobStatus.TRANSCRIBED
         attempts = await _attempts_for_job(async_session, job)
@@ -442,12 +440,10 @@ class TestPipelineFailureFlow:
 
         services = _build_services(default_session_factory)
         queued_job = await services.jobs.read_job(job_id=upload_result.job_id, session=async_session)
-        processed = queued_job is not None
+        assert queued_job is not None
-        if queued_job is not None:
+        await advance_job(job=queued_job, services=services, settings=settings, session=async_session)
-            await advance_job(job=queued_job, services=services, settings=settings, session=async_session)
         job = await services.jobs.read_job(job_id=upload_result.job_id, session=async_session)
 
-        assert processed is True
         assert job is not None
         assert job.status == JobStatus.FAILED
         attempts = await _attempts_for_job(async_session, job)

tests/services/test_workflows_reliability.py

@@ -154,8 +154,8 @@ class TestWorkflowReliability:
             await session.commit()
             loaded = await services.jobs.read_job(job_id=job.id, session=session)
 
-        setup_seconds = 0.40
+        setup_seconds = 0.25
-        budget_seconds = 0.20
+        budget_seconds = 0.15
         real_build = workflows_module.build_provider_input
 
         def _slow_build(source_arg, **kwargs):
@@ -188,9 +188,9 @@ class TestWorkflowReliability:
         assert len(attempts) == 1
         duration_ms = attempts[0].duration_ms
 
-        # At or just above the budget, and well clear of budget + setup.
+        # At or above the timeout budget, and still well below setup + timeout.
-        assert duration_ms >= int(budget_seconds * 1000 * 0.9)
+        assert duration_ms >= int(budget_seconds * 1000 * 0.7)
-        assert duration_ms < int((budget_seconds + setup_seconds) * 1000 * 0.9)
+        assert duration_ms < int((budget_seconds + setup_seconds) * 1000 * 0.75)
 
     @pytest.mark.asyncio
     async def test_attempt_metadata_persists_provider_and_processing_durations(

tests/test_orphan_sweep.py

@@ -114,7 +114,7 @@ def _orphans() -> dict[str, str]:
 def test_public_definitions_are_discovered():
     """Guard the guard: the sweep is meaningless if nothing is scanned."""
     definitions = _public_definitions()
-    assert len(definitions) >= 200
+    assert len(definitions) >= 260
     assert "create_app" in definitions
 
 

tests/test_traceability.py

@@ -51,9 +51,7 @@ class TestMvpRequirementTraceability:
         """Each MVP in-scope REQ id maps to at least one existing test path."""
         project_root = Path(__file__).resolve().parents[1]
 
-        assert MVP_REQUIREMENT_TEST_MAP
         for requirement_id, mapped_tests in MVP_REQUIREMENT_TEST_MAP.items():
-            assert requirement_id.startswith("REQ-")
             assert mapped_tests, f"No mapped tests for {requirement_id}"
 
             for relative_path in mapped_tests: