test(gfql): engagement pins from the 7-mode routes-off replay carry the route_engaged marker

Replay at the harness head (scratchpad ledger kept under reviews/2054/): every
remaining single-route id was an engagement pin (a served spy, a trace or a
lane-specific explain step) or the #2058 dtype class; the all-off residue adds
four combined-route engagement pins and the #2034 duplicate-id case.

Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01QztW7jYsDd66e8rb8pJNQA

Author: lmeyerov

graphistry/tests/compute/gfql/cypher/test_lowering.py

@@ -18626,6 +18626,7 @@ def test_t6_col_stats_decisions_are_visible_in_the_trace() -> None:
         outcomes={"nodes.id": "served", "edges.s": "served"})
 
 
+@pytest.mark.route_engaged("cypher-fast")
 def test_t6_assert_col_stats_helper_fails_loudly() -> None:
     """The helper must FAIL when the optimization did not fire -- an engagement
     pin that cannot fail is worse than none, which is the whole failure mode
@@ -19225,6 +19226,7 @@ def _mk_h3_case_data(fixture: str) -> Tuple[pd.DataFrame, pd.DataFrame]:
     raise AssertionError(f"unknown fixture {fixture}")
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ["polars", "polars-gpu"])
 @pytest.mark.parametrize("label,fixture,query", _H3_DIFFERENTIAL_CASES, ids=[c[0] for c in _H3_DIFFERENTIAL_CASES])
 def test_h3_fused_two_hop_count_matches_eager_twin_and_pandas(
@@ -19249,6 +19251,7 @@ def test_h3_fused_two_hop_count_matches_eager_twin_and_pandas(
     assert fused == oracle, f"{label}: fused lane diverged from the pandas oracle"
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ["polars", "polars-gpu"])
 def test_h3_fused_two_hop_count_empty_match_counts_zero(engine: str, monkeypatch: pytest.MonkeyPatch) -> None:
     """openCypher counts over no rows as 0 -- not an empty frame."""
@@ -19359,6 +19362,7 @@ def test_h3_two_hop_count_fast_path_has_no_order_by_or_limit_surface(suffix: str
     assert _two_hop_count_alias(compiled.chain) == expect_alias
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ["polars", "polars-gpu"])
 def test_h3_fused_two_hop_count_handles_degenerate_bindings(engine: str, monkeypatch: pytest.MonkeyPatch) -> None:
     """The node key may share a name with an endpoint column, and source/destination may be bound

graphistry/tests/compute/gfql/index/test_degree_consult.py

@@ -102,6 +102,7 @@ def test_identity_anchors_to_the_bound_frame_not_the_partition() -> None:
     assert fact.source_ref is g._edges
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ENGINES)
 @pytest.mark.parametrize("n_p,n_c", [(3, 3), (5, 1), (2, 8), (7, 2)])
 def test_slice_is_exact_across_domain_shapes(n_p: int, n_c: int, engine: str) -> None:
@@ -117,6 +118,7 @@ def test_slice_is_exact_across_domain_shapes(n_p: int, n_c: int, engine: str) ->
     assert value == oracle
 
 
+@pytest.mark.route_engaged("cypher-fast")
 def test_gapped_node_space_builds_facts_and_stays_exact() -> None:
     """Density is NOT required for the degree arrays: ids absent from the span
     contribute ZERO to the dot, so a gapped node space builds valid facts. (The
@@ -137,6 +139,7 @@ def test_gapped_node_space_builds_facts_and_stays_exact() -> None:
     assert used, "P-domain [0,2] is dense, so the kernel must consult the fact"
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("seed", range(6))
 def test_differential_vs_the_scan_on_random_typed_graphs(seed: int) -> None:
     """Values must be identical with and without the fact, on arbitrary degree

graphistry/tests/compute/gfql/index/test_index.py

@@ -1465,6 +1465,7 @@ def _polars_indexed_graph():
     return g.gfql_index_all(engine="polars")
 
 
+@pytest.mark.route_engaged("index-hop")
 def test_auto_engine_gfql_serves_polars_index_1767_cliff():
     """#1767 cliff pin: polars frames + explicit polars index + gfql with NO engine
     argument must serve path=index on engine=polars (AUTO routes native, so the
@@ -1701,6 +1702,7 @@ def test_col_stats_auto_narrows_lazy_frames(self):
         gi = gl.gfql_index_col_stats()  # AUTO on lazy frames must not crash
         assert gi is not None
 
+    @pytest.mark.route_engaged("index-hop")
     def test_inversion_auto_index_auto_gfql_serves_polars_index(self):
         """THE INVERSION PIN. The exact scenario the retracted #1767 regressed
         to the scan floor: ``gfql_index_all()`` with NO engine + ``g.gfql(<index-

graphistry/tests/compute/gfql/index/test_index_gpu_edge_match.py

@@ -85,6 +85,7 @@ def _match_value(null_col_dtype: str):
     return {"string": "1", "boolean": True}.get(null_col_dtype, 1)
 
 
+@pytest.mark.route_engaged("index-hop")
 @pytest.mark.parametrize("engine", ["cudf", "polars-gpu"])
 @pytest.mark.parametrize("null_col_dtype", NULL_DTYPES)
 def test_null_bearing_edge_predicate_matches_the_pandas_oracle_on_device(engine, null_col_dtype):
@@ -110,6 +111,7 @@ def pairs(gg):
     assert pairs(got) == pairs(oracle), f"[{engine}/{null_col_dtype}] diverged from pandas"
 
 
+@pytest.mark.route_engaged("index-hop")
 @pytest.mark.parametrize("engine", ["cudf", "polars-gpu"])
 def test_empty_candidate_batch_on_device(engine):
     """A seed with no matching typed edges yields a zero-length gather map on device."""

graphistry/tests/compute/gfql/index/test_indexed_bindings.py

@@ -405,6 +405,7 @@ def test_connected_path_bag_trace_and_lifecycle(
 ]
 
 
+@pytest.mark.route_engaged("indexed-kernel")
 @pytest.mark.parametrize("engine", ENGINES)
 @pytest.mark.parametrize("query", STANDARD_DERIVED_POSITIVES)
 def test_standard_derived_connected_parity(
@@ -454,6 +455,7 @@ def unexpected_traversal(*args: Any, **kwargs: Any) -> Any:
     _assert_decision(decisions[0], seam="connected_bindings", served=True)
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ENGINES)
 def test_destination_property_projection_dtype_parity(
     engine: str,
@@ -726,6 +728,7 @@ def test_node_property_index_prefers_the_most_selective_column(
         pytest.param({"grp": 0}, "grp", False, id="unselective-keeps-scan"),
     ],
 )
+@pytest.mark.route_engaged("index-hop", "indexed-kernel")
 def test_node_property_index_cost_gate_under_policy_use(
     seed: Dict[str, Any],
     indexed_column: str,

graphistry/tests/compute/gfql/routes/test_route_harness.py

@@ -154,6 +154,7 @@ def test_admitted_shape_is_served_and_matches_the_general_path(case: Case, reque
         pytest.xfail(f"{case.id}: admitted by the predicate, declined by the lane body (attenuation ledger)")
 
 
+@pytest.mark.route_engaged("native-fast", "polars-plain", "polars-seeded")
 def test_every_route_serves_most_of_what_it_admits(monkeypatch):
     """A lane that declines most admitted shapes has a predicate that no longer describes it."""
     per_route: Dict[str, List[int]] = {}

graphistry/tests/compute/gfql/test_native_seed_lane_explain.py

@@ -44,7 +44,7 @@ def test_node_only_lookup_served_by_the_property_index_is_explained(engine):
     assert len(g.gfql(NODE_ONLY, engine=engine, index_policy="use")._nodes) == 1
 
 
-@pytest.mark.route_engaged("native-fast")
+@pytest.mark.route_engaged("native-fast", "polars-seeded")
 @pytest.mark.parametrize("engine", ENGINES)
 def test_seeded_typed_hop_served_by_the_resident_indexes_is_explained(engine):
     g = _graph(engine)

graphistry/tests/compute/gfql/test_polars_native_seed_resolution.py

@@ -33,6 +33,7 @@ def _graph(reverse=False, indexed=True, padding=0):
     return g.gfql_index_all(engine="polars").gfql_index_node_props(["id"], engine="polars") if indexed else g
 
 
+@pytest.mark.route_engaged("polars-seeded")
 @pytest.mark.parametrize("reverse", [False, True])
 @pytest.mark.parametrize("indexed", [False, True])
 @pytest.mark.parametrize("seed", [{"id": 104}, {"kind": "Message"}, {"id": 105}, {"id": 999}])
@@ -73,6 +74,7 @@ def spy(*args):
 _NAMED_TYPED_HOP = [n({"id": 104}, name="m"), e_forward({"type": "T"}, name="e"), n({"kind": "Person"}, name="p")]
 
 
+@pytest.mark.route_engaged("polars-seeded")
 def test_native_seeded_hop_is_served_from_the_index_and_traced():
     from graphistry.compute.gfql.index import index_trace
     g = _graph()
@@ -98,6 +100,7 @@ def test_native_seeded_hop_declines_without_a_usable_index(policy, monkeypatch):
     assert_frame_equal(fast._edges, full._edges)
 
 
+@pytest.mark.route_engaged("polars-seeded")
 @pytest.mark.parametrize("single_node", [False, True])
 def test_native_property_seed_uses_resident_index(single_node, monkeypatch):
     import graphistry.compute.gfql.index.bindings as bindings

graphistry/tests/compute/gfql/test_rewrite_param_discard.py

@@ -210,6 +210,7 @@ def test_indexed_bypass_table_edges_survives_a_projection(engine: str) -> None:
                "(index/bindings.py gate), so polars-gpu always takes the scan path",
     )),
 ])
+@pytest.mark.route_engaged("indexed-kernel")
 def test_indexed_bypass_still_serves_a_bare_rows(engine: str) -> None:
     """THE NEGATIVE SIDE: declining on a non-default `table` must not decline everything.
 

graphistry/tests/compute/gfql/test_seeded_node_lookup_fastpath.py

@@ -114,6 +114,7 @@ def test_node_lookup_engages_with_parity(engine, indexed, q, label):
     _assert_parity(_graph(engine, indexed), engine, q, "seeded_node_lookup")
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ENGINES)
 def test_node_lookup_matches_independent_oracle(engine):
     g = _graph(engine)
@@ -263,6 +264,7 @@ def test_hub_seed_over_the_frontier_gate_keeps_parity(engine, indexed):
     pd.testing.assert_frame_equal(_canon(fast), _canon(full))
 
 
+@pytest.mark.route_engaged("cypher-fast")
 @pytest.mark.parametrize("engine", ENGINES)
 def test_seed_matching_several_nodes_projects_each_seed(engine):
     """A non-unique seed predicate: every seed row pairs with its own destinations."""