refactor(services): rename tests + strip internal planning vocabulary

Renames test files / directory / functions to descriptive names and
strips internal roadmap IDs (SVC-XX, CNT-XX, IDX-06, D-XX, phase_04).

- Directory: phase_04_service_init_parity/ -> service_init_parity/
- Files:
  - test_svc01_starter_hash_cache.py -> test_starter_project_hash_gate.py
  - test_svc02_dependency_review.py -> test_lifespan_dependency_review.py
  - test_svc02_gather_structure.py -> test_lifespan_gather_structure.py
  - test_svc03_mcp_event_readiness.py -> test_mcp_event_readiness.py
  - test_svc04_restart_integration.py -> test_langflow_restart_parity.py
- Functions: test_svc04_* -> descriptive names

No behavioral changes.

Author: ogabrielluiz

src/backend/base/langflow/initial_setup/starter_project_hash.py

@@ -6,7 +6,7 @@
 short-circuit the full starter-project re-sync on restarts where nothing
 changed.
 
-Failure modes (D-04): missing, unreadable, or corrupt hash files all fall
+Failure modes: missing, unreadable, or corrupt hash files all fall
 through to a full re-sync. ``LANGFLOW_FORCE_STARTER_RESYNC=1`` bypasses the
 comparison. Write failures (read-only root filesystem, e.g. container
 deployments) log at debug level and never raise -- mirroring the
@@ -45,7 +45,7 @@ async def compute_starter_projects_hash(starter_folder: anyio.Path) -> str:
     (source-only checkout without ``pip install -e .``), the sentinel
     ``"unknown"`` is substituted (Pattern F / Pitfall 5). The hash remains
     stable within such an environment but will invalidate whenever the
-    fallback fires in a fresh environment -- acceptable per D-01.
+    fallback fires in a fresh environment -- acceptable .
     """
     try:
         pkg_version = version("lfx")
@@ -77,7 +77,7 @@ async def read_hash_file_safe(hash_path: Path) -> str | None:
     - Corrupt content (first non-comment line is not 64 hex chars)
 
     The caller is expected to treat ``None`` as a cache miss and fall through
-    to a full re-sync (D-04).
+    to a full re-sync.
     """
     try:
         async with aiofiles.open(str(hash_path), encoding="utf-8") as f:
@@ -132,10 +132,10 @@ async def run_starter_projects_hash_gate(
     hash_path: Path,
     sync_fn: Callable[[], Awaitable[Any]],
 ) -> bool:
-    """Execute the SVC-01 hash-gated starter-project sync.
+    """Execute the hash-gated starter-project sync.
 
     This helper encapsulates the hash compare / sync / write sequence so both
-    ``main.py`` (inside its ``FileLock``) and the Phase 4 parity tests invoke
+    ``main.py`` (inside its ``FileLock``) and the parity tests invoke
     the exact same code path. ``sync_fn`` is a zero-arg coroutine factory the
     caller uses to pass in ``create_or_update_starter_projects(all_types_dict)``
     with ``all_types_dict`` already bound.

src/backend/base/langflow/main.py

@@ -207,17 +207,17 @@ async def lifespan(_app: FastAPI):
         try:
             start_time = asyncio.get_event_loop().time()
 
-            # SVC-03 (D-12): Event constructed inside lifespan so it binds to the running loop.
+            # Event constructed inside lifespan so it binds to the running loop.
             # Module-level asyncio.Event() would leak across pytest event loops (Pitfall 1, same
-            # root cause as IDX-01's asyncio.Lock issue on Python 3.13/3.14).
+            # root cause as's asyncio.Lock issue on Python 3.13/3.14).
             starter_projects_ready_event = asyncio.Event()
 
             await logger.adebug("Initializing services")
             await initialize_services(fix_migration=fix_migration)
             await logger.adebug(f"Services initialized in {asyncio.get_event_loop().time() - start_time:.2f}s")
 
-            # SVC-02 wave 1: independent filesystem / in-memory ops.
-            # D-09 service-dependency review (enforced by D-10 test; every task passed to gather MUST have a row):
+            # wave 1: independent filesystem / in-memory ops.
+            # service-dependency review (enforced by test; every task passed to gather MUST have a row):
             #
             # | Task                  | Reads                                      | Writes                            |
             # |-----------------------|--------------------------------------------|-----------------------------------|
@@ -242,8 +242,8 @@ async def lifespan(_app: FastAPI):
                     f"Default super user initialized in {asyncio.get_event_loop().time() - current_time:.2f}s"
                 )
 
-            # SVC-02 wave 2: independent post-superuser ops.
-            # D-09 service-dependency review (enforced by D-10 test; every task passed to gather MUST have a row):
+            # wave 2: independent post-superuser ops.
+            # service-dependency review (enforced by test; every task passed to gather MUST have a row):
             #
             # | Task                          | Reads                                 | Writes                         |
             # |-------------------------------|---------------------------------------|--------------------------------|
@@ -285,7 +285,7 @@ async def lifespan(_app: FastAPI):
             lock = FileLock(lock_file, timeout=1)
             try:
                 with lock:
-                    # SVC-01: hash-gated re-sync. Hash read / compute / write all run
+                    # hash-gated re-sync. Hash read / compute / write all run
                     # inside the FileLock to preserve multi-worker TOCTOU safety (the
                     # other worker either wrote the up-to-date hash before releasing
                     # the lock, or the lock contention path fires below).
@@ -309,10 +309,10 @@ async def lifespan(_app: FastAPI):
                             f"Starter projects hash matches; skipped re-sync in "
                             f"{asyncio.get_event_loop().time() - current_time:.2f}s"
                         )
-                    # SVC-03 producer (D-11): fire on both match and miss paths inside the
+                    # producer: fire on both match and miss paths inside the
                     # FileLock, but NOT in a finally clause. If create_or_update_starter_projects
                     # or the hash read raises, DO NOT set the event -- let the 60s consumer
-                    # timeout (D-13) surface the failure as warn-and-continue degraded mode.
+                    # timeout surface the failure as warn-and-continue degraded mode.
                     starter_projects_ready_event.set()
             except TimeoutError:
                 # Another process has the lock
@@ -378,10 +378,10 @@ async def lifespan(_app: FastAPI):
             await logger.adebug(f"Total initialization time: {total_time:.2f}s")
 
             async def delayed_init_mcp_servers():
-                # SVC-03 consumer (D-11/D-13): replace the previously hardcoded 10-second
+                # consumer (D-11/D-13): replace the previously hardcoded 10-second
                 # coordination sleep with a bounded wait on the starter_projects_ready_event
                 # set by the FileLock producer. On timeout, log a warning and proceed with
-                # MCP init anyway (warn-and-continue degraded mode per D-13). Closure captures
+                # MCP init anyway (warn-and-continue degraded mode ). Closure captures
                 # the Event because this function is defined inline inside lifespan (Pitfall 6).
                 try:
                     await asyncio.wait_for(starter_projects_ready_event.wait(), timeout=60.0)
@@ -396,7 +396,7 @@ async def delayed_init_mcp_servers():
                     await logger.adebug(f"MCP servers loaded in {asyncio.get_event_loop().time() - current_time:.2f}s")
                 except Exception as e:  # noqa: BLE001
                     await logger.awarning(f"First MCP server initialization attempt failed: {e}")
-                    await asyncio.sleep(5.0)  # D-14: retain transient-DB-error retry guard
+                    await asyncio.sleep(5.0)  #: retain transient-DB-error retry guard
                     current_time = asyncio.get_event_loop().time()
                     await logger.adebug("Retrying MCP servers initialization")
                     try:

src/backend/base/langflow/server.py

@@ -74,7 +74,7 @@ def load_config(self) -> None:
         config = {key: value for key, value in self.options.items() if key in self.cfg.settings and value is not None}
         for key, value in config.items():
             self.cfg.set(key.lower(), value)
-        # CNT-04: reset fork-unsafe resources in each worker after fork.
+        # reset fork-unsafe resources in each worker after fork.
         # See _langflow_post_fork below + TelemetryService.start() guard.
         self.cfg.set("post_fork", _langflow_post_fork)
 
@@ -91,15 +91,15 @@ def _langflow_post_fork(server, worker) -> None:  # noqa: ARG001
     asyncio.get_event_loop, no await).
 
     Current responsibilities (CNT-04 fork-hazard audit, RESEARCH.md section
-    "Fork Hazard Audit (D-05)"):
+    "Fork Hazard Audit"):
 
     * TelemetryService.client (httpx.AsyncClient) — reset to None so that
       TelemetryService.start() reconstructs it inside the worker's event
       loop. httpx.AsyncClient has no synchronous .close(), so we cannot
       aclose() here; replacing the reference is the correct pattern
       (Pitfall 1).
 
-    All other hazards audited in Phase 5 (SQLAlchemy engine, asyncio locks,
+    All other hazards audited in (SQLAlchemy engine, asyncio locks,
     ComponentCache.all_types_dict, Redis pool, asyncio.create_task, open
     file descriptors) are SAFE by construction — see the phase 05 SUMMARY
     for evidence.

src/backend/tests/phase_04_service_init_parity/__init__.py

@@ -0,0 +1 @@
+# service-init parity / lifespan assertion tests.

src/backend/tests/phase_04_service_init_parity/fixtures/__init__.py

@@ -1,9 +1,9 @@
-"""AST helpers for Phase 4 structural assertions.
+"""AST helpers for structural assertions.
 
 Source: docs.python.org/3/library/ast.html
 
-These helpers support Phase 4 D-06 (SVC-02 gather structure), D-07
-(SVC-03 ``asyncio.sleep(10.0)`` absence), and D-10 (gather-review-table
+These helpers support (SVC-02 gather structure),
+(SVC-03 ``asyncio.sleep(10.0)`` absence), and (gather-review-table
 enforcement) tests. They parse ``src/backend/base/langflow/main.py`` once and
 expose a tiny query API over the AST.
 """
@@ -35,7 +35,7 @@ def find_calls_to(tree: ast.AST, qualname: str) -> list[ast.Call]:
     - Two-segment qualified names ("asyncio.gather") matched against
       ``Call(func=Attribute(value=Name('asyncio'), attr='gather'))``.
 
-    Longer dotted paths are not currently needed by Phase 4 and are not
+    Longer dotted paths are not currently needed by and are not
     supported.
     """
     parts = qualname.split(".")
@@ -62,7 +62,7 @@ def find_sleep_with_value(tree: ast.AST, value: float) -> list[ast.Call]:
 
     Non-literal arguments (e.g. ``asyncio.sleep(timeout_var)``) are ignored --
     they are not regressions of the Phase 3 / 4 "no magic sleep(10.0)"
-    constraint. The literal check exactly matches what D-07 absence assertions
+    constraint. The literal check exactly matches what absence assertions
     care about.
     """
     return [
@@ -80,7 +80,7 @@ def extract_gather_task_names(call: ast.Call) -> list[str]:
 
     For ``asyncio.gather(foo(), bar.baz())`` returns ``["foo", "baz"]``.
 
-    Two levels of unwrapping are applied so the D-10 review-table enforcement
+    Two levels of unwrapping are applied so the review-table enforcement
     test sees the *actual* task names regardless of the transport wrapper used:
 
     1. ``_safe_step("name", real_call())`` -> look at ``arg.args[1]``. Phase 4

src/backend/tests/phase_04_service_init_parity/fixtures/starter_minimal/__init__.py

@@ -1,4 +1,4 @@
-"""Phase 4 service-init parity test fixtures.
+"""service-init parity test fixtures.
 
 Provides a phase-local ``tmp_config_dir`` that redirects
 ``LANGFLOW_CONFIG_DIR`` + ``LANGFLOW_DATABASE_URL`` into a per-test tmp
@@ -32,7 +32,7 @@ def tmp_config_dir(tmp_path, monkeypatch):
     settings_service = get_settings_service()
     config_dir = tmp_path / "config"
     config_dir.mkdir(parents=True, exist_ok=True)
-    db_path = tmp_path / "test_phase_04.db"
+    db_path = tmp_path / "test_.db"
     test_db_url = f"sqlite:///{db_path}"
 
     original_config = os.getenv("LANGFLOW_CONFIG_DIR")