From d041f33c2fc51c62b091003e7c8e3f4a54672836 Mon Sep 17 00:00:00 2001 From: yucheng Date: Sat, 26 Sep 2026 08:23:38 +0000 Subject: [PATCH] test(integration): split operator db-span asserts by trace scope Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> --- .../integration/observability/test_otel_excluded_services.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tests/integration/observability/test_otel_excluded_services.py b/tests/integration/observability/test_otel_excluded_services.py index de478e3985d..30e4ee64531 100644 --- a/tests/integration/observability/test_otel_excluded_services.py +++ b/tests/integration/observability/test_otel_excluded_services.py @@ -185,9 +185,11 @@ def test_excluded_services_drops_db_spans_at_tenant_only( ) operator_trace: Final = _trace_id(audit_sinks.operator, traffic) assert operator_trace == tenant_trace + trace_systems: Final = _db_systems(_trace_spans(audit_sinks.operator, operator_trace)) + assert "redis" in trace_systems, f"operator trace lost redis spans: {trace_systems}" _, all_operator = recorded_spans(audit_sinks.operator, op_start) operator_systems: Final = _db_systems(all_operator) - assert {"redis", "postgresql"} <= operator_systems, f"operator lost db spans: {operator_systems}" + assert "postgresql" in operator_systems, f"operator lost aux db spans: {operator_systems}" _, all_tenant = recorded_spans(audit_sinks.tenant, ten_start) names: Final = sorted(str(span["name"]) for span in all_tenant) assert _db_systems(all_tenant) == set(), f"aux db spans reached tenant: {names}"