chore(release): bump to v0.116.0 (#10626)

Co-authored-by: primus-bot[bot] <171087277+primus-bot[bot]@users.noreply.github.com>

deploy/docker-swarm/docker-compose.ha.yaml

@@ -190,7 +190,7 @@ services:
       # - ../common/clickhouse/storage.xml:/etc/clickhouse-server/config.d/storage.xml
   signoz:
     !!merge <<: *db-depend
-    image: signoz/signoz:v0.115.0
+    image: signoz/signoz:v0.116.0
     ports:
       - "8080:8080" # signoz port
     #   - "6060:6060"     # pprof port

deploy/docker-swarm/docker-compose.yaml

@@ -117,7 +117,7 @@ services:
       # - ../common/clickhouse/storage.xml:/etc/clickhouse-server/config.d/storage.xml
   signoz:
     !!merge <<: *db-depend
-    image: signoz/signoz:v0.115.0
+    image: signoz/signoz:v0.116.0
     ports:
       - "8080:8080" # signoz port
     volumes:

deploy/docker/docker-compose.ha.yaml

@@ -181,7 +181,7 @@ services:
       # - ../common/clickhouse/storage.xml:/etc/clickhouse-server/config.d/storage.xml
   signoz:
     !!merge <<: *db-depend
-    image: signoz/signoz:${VERSION:-v0.115.0}
+    image: signoz/signoz:${VERSION:-v0.116.0}
     container_name: signoz
     ports:
       - "8080:8080" # signoz port

deploy/docker/docker-compose.yaml

@@ -109,7 +109,7 @@ services:
       # - ../common/clickhouse/storage.xml:/etc/clickhouse-server/config.d/storage.xml
   signoz:
     !!merge <<: *db-depend
-    image: signoz/signoz:${VERSION:-v0.115.0}
+    image: signoz/signoz:${VERSION:-v0.116.0}
     container_name: signoz
     ports:
       - "8080:8080" # signoz port

pkg/querier/builder_query.go

@@ -361,10 +361,6 @@ func (q *builderQuery[T]) executeWindowList(ctx context.Context) (*qbtypes.Resul
 		if err != nil {
 			return nil, err
 		}
-		// skip = true means we have indentified from the query itself that we don't need to execute this bucket
-		if stmt.Skip {
-			continue
-		}
 		warnings = stmt.Warnings
 		warningsDocURL = stmt.WarningsDocURL
 		// Execute with proper context for partial value detection

pkg/telemetrytraces/statement_builder.go

@@ -121,18 +121,8 @@ func (b *traceQueryStatementBuilder) Build(
 			if !ok {
 				b.logger.DebugContext(ctx, "failed to get trace time range", "trace_ids", traceIDs)
 			} else if traceStart > 0 && traceEnd > 0 {
-				// we don't  need to query if the start and end are non overlapping
-				if uint64(traceStart) > end || uint64(traceEnd) < start {
-					return &qbtypes.Statement{Skip: true}, nil
-				}
-
-				// clamp start/end to trace time range to avoid overlap between buckets
-				if uint64(traceStart) > start {
-					start = uint64(traceStart)
-				}
-				if uint64(traceEnd) < end {
-					end = uint64(traceEnd)
-				}
+				start = uint64(traceStart)
+				end = uint64(traceEnd)
 				b.logger.DebugContext(ctx, "optimized time range for traces", "trace_ids", traceIDs, "start", start, "end", end)
 			}
 		}

pkg/types/querybuildertypes/querybuildertypesv5/qb.go

@@ -47,7 +47,6 @@ type Statement struct {
 	Args           []any
 	Warnings       []string
 	WarningsDocURL string
-	Skip           bool // don't run this query
 }
 
 // StatementBuilder builds the query.

tests/integration/src/querier/04_traces.py

@@ -696,6 +696,7 @@ def test_traces_list_with_corrupt_data(
     assert response.status_code == status_code
 
     if response.status_code == HTTPStatus.OK:
+
         if not results(traces):
             # No results expected
             assert response.json()["data"]["data"]["results"][0]["rows"] is None
@@ -2025,249 +2026,3 @@ def test_traces_fill_zero_formula_with_group_by(
             expected_by_ts=expectations[service_name],
             context=f"traces/fillZero/F1/{service_name}",
         )
-
-
-def test_traces_list_filter_by_trace_id(
-    signoz: types.SigNoz,
-    create_user_admin: None,  # pylint: disable=unused-argument
-    get_token: Callable[[str, str], str],
-    insert_traces: Callable[[List[Traces]], None],
-) -> None:
-    """
-    Tests that filtering by trace_id:
-    1. Returns the matching span (narrow window, single bucket).
-    2. Does not return duplicate spans when the query window spans multiple
-       exponential buckets (>1 h) — regression test for the expand-vs-clamp bug.
-    3. Returns no results when the query window does not contain the trace.
-    """
-    target_trace_id = TraceIdGenerator.trace_id()
-    other_trace_id = TraceIdGenerator.trace_id()
-    span_id_root = TraceIdGenerator.span_id()
-    other_span_id = TraceIdGenerator.span_id()
-
-    now = datetime.now(tz=timezone.utc).replace(second=0, microsecond=0)
-
-    common_resources = {
-        "deployment.environment": "production",
-        "service.name": "trace-filter-service",
-        "cloud.provider": "integration",
-    }
-
-    insert_traces(
-        [
-            Traces(
-                timestamp=now - timedelta(seconds=10),
-                duration=timedelta(seconds=5),
-                trace_id=target_trace_id,
-                span_id=span_id_root,
-                parent_span_id="",
-                name="root-span",
-                kind=TracesKind.SPAN_KIND_SERVER,
-                status_code=TracesStatusCode.STATUS_CODE_OK,
-                status_message="",
-                resources=common_resources,
-                attributes={"http.request.method": "GET"},
-            ),
-            # span from a different trace — must not appear in results
-            Traces(
-                timestamp=now - timedelta(seconds=5),
-                duration=timedelta(seconds=1),
-                trace_id=other_trace_id,
-                span_id=other_span_id,
-                parent_span_id="",
-                name="other-root-span",
-                kind=TracesKind.SPAN_KIND_SERVER,
-                status_code=TracesStatusCode.STATUS_CODE_OK,
-                status_message="",
-                resources=common_resources,
-                attributes={},
-            ),
-        ]
-    )
-
-    token = get_token(USER_ADMIN_EMAIL, USER_ADMIN_PASSWORD)
-
-    trace_filter = f"trace_id = '{target_trace_id}'"
-
-    def _query(start_ms: int, end_ms: int) -> List:
-        response = make_query_request(
-            signoz,
-            token,
-            start_ms=start_ms,
-            end_ms=end_ms,
-            request_type="raw",
-            queries=[
-                {
-                    "type": "builder_query",
-                    "spec": {
-                        "name": "A",
-                        "signal": "traces",
-                        "limit": 100,
-                        "offset": 0,
-                        "filter": {"expression": trace_filter},
-                        "order": [{"key": {"name": "timestamp"}, "direction": "desc"}],
-                        "selectFields": [
-                            {
-                                "name": "name",
-                                "fieldDataType": "string",
-                                "fieldContext": "span",
-                                "signal": "traces",
-                            }
-                        ],
-                    },
-                }
-            ],
-        )
-        assert response.status_code == HTTPStatus.OK
-        assert response.json()["status"] == "success"
-        return response.json()["data"]["data"]["results"][0]["rows"] or []
-
-    now_ms = int(now.timestamp() * 1000)
-
-    # --- Test 1: narrow window (single bucket, <1 h) ---
-    narrow_start_ms = int((now - timedelta(minutes=5)).timestamp() * 1000)
-    narrow_rows = _query(narrow_start_ms, now_ms)
-
-    assert len(narrow_rows) == 1, (
-        f"Expected 1 span for trace_id filter (narrow window), got {len(narrow_rows)}"
-    )
-    assert narrow_rows[0]["data"]["span_id"] == span_id_root
-    assert narrow_rows[0]["data"]["trace_id"] == target_trace_id
-
-    # --- Test 2: wide window (>1 h, triggers multiple exponential buckets) ---
-    # should just return 1 span, not duplicate
-    wide_start_ms = int((now - timedelta(hours=12)).timestamp() * 1000)
-    wide_rows = _query(wide_start_ms, now_ms)
-
-    assert len(wide_rows) == 1, (
-        f"Expected 1 span for trace_id filter (wide window, multi-bucket), "
-        f"got {len(wide_rows)} — possible duplicate-span regression"
-    )
-    assert wide_rows[0]["data"]["span_id"] == span_id_root
-    assert wide_rows[0]["data"]["trace_id"] == target_trace_id
-
-    # --- Test 3: window that does not contain the trace returns no results ---
-    past_start_ms = int((now - timedelta(hours=6)).timestamp() * 1000)
-    past_end_ms = int((now - timedelta(hours=2)).timestamp() * 1000)
-    past_rows = _query(past_start_ms, past_end_ms)
-
-    assert len(past_rows) == 0, (
-        f"Expected 0 spans for trace_id filter outside time window, "
-        f"got {len(past_rows)}"
-    )
-
-
-def test_traces_list_filter_by_trace_id_cross_bucket(
-    signoz: types.SigNoz,
-    create_user_admin: None,  # pylint: disable=unused-argument
-    get_token: Callable[[str, str], str],
-    insert_traces: Callable[[List[Traces]], None],
-) -> None:
-    """
-    Regression test for multi-bucket trace_id queries.
-
-    Setup: a single trace with two spans placed in different exponential buckets.
-      makeBuckets over a 3-hour window produces (newest-first):
-        bucket 1: [now-1h,  now]       ← span_a lives here (now-30min)
-        bucket 2: [now-3h,  now-1h]    ← span_b lives here (now-90min)
-
-    Without the fix: both buckets expanded their window to [traceStart, traceEnd]
-    and therefore each returned both spans → 4 rows total (duplicates).
-
-    With the fix: each bucket is tied to its intersection with the trace range,
-    so bucket 1 returns span_a and bucket 2 returns span_b → exactly 2 rows.
-    """
-    trace_id = TraceIdGenerator.trace_id()
-    span_id_a = TraceIdGenerator.span_id()
-    span_id_b = TraceIdGenerator.span_id()
-
-    now = datetime.now(tz=timezone.utc).replace(second=0, microsecond=0)
-
-    common_resources = {
-        "deployment.environment": "production",
-        "service.name": "cross-bucket-service",
-        "cloud.provider": "integration",
-    }
-
-    insert_traces(
-        [
-            # span_a: sits in bucket 1 [now-1h, now]
-            Traces(
-                timestamp=now - timedelta(minutes=30),
-                duration=timedelta(seconds=1),
-                trace_id=trace_id,
-                span_id=span_id_a,
-                parent_span_id="",
-                name="span-a",
-                kind=TracesKind.SPAN_KIND_SERVER,
-                status_code=TracesStatusCode.STATUS_CODE_OK,
-                status_message="",
-                resources=common_resources,
-                attributes={},
-            ),
-            # span_b: sits in bucket 2 [now-3h, now-1h]
-            Traces(
-                timestamp=now - timedelta(minutes=90),
-                duration=timedelta(seconds=1),
-                trace_id=trace_id,
-                span_id=span_id_b,
-                parent_span_id=span_id_a,
-                name="span-b",
-                kind=TracesKind.SPAN_KIND_CLIENT,
-                status_code=TracesStatusCode.STATUS_CODE_OK,
-                status_message="",
-                resources=common_resources,
-                attributes={},
-            ),
-        ]
-    )
-
-    token = get_token(USER_ADMIN_EMAIL, USER_ADMIN_PASSWORD)
-
-    # 3-hour window forces makeBuckets to create two buckets:
-    #   bucket 1: [now-1h, now]
-    #   bucket 2: [now-3h, now-1h]
-    start_ms = int((now - timedelta(hours=3)).timestamp() * 1000)
-    end_ms = int(now.timestamp() * 1000)
-
-    response = make_query_request(
-        signoz,
-        token,
-        start_ms=start_ms,
-        end_ms=end_ms,
-        request_type="raw",
-        queries=[
-            {
-                "type": "builder_query",
-                "spec": {
-                    "name": "A",
-                    "signal": "traces",
-                    "limit": 100,
-                    "offset": 0,
-                    "filter": {"expression": f"trace_id = '{trace_id}'"},
-                    "order": [{"key": {"name": "timestamp"}, "direction": "desc"}],
-                    "selectFields": [
-                        {
-                            "name": "name",
-                            "fieldDataType": "string",
-                            "fieldContext": "span",
-                            "signal": "traces",
-                        }
-                    ],
-                },
-            }
-        ],
-    )
-
-    assert response.status_code == HTTPStatus.OK
-    assert response.json()["status"] == "success"
-
-    rows = response.json()["data"]["data"]["results"][0]["rows"] or []
-
-    assert len(rows) == 2, (
-        f"Expected exactly 2 spans (one per bucket), got {len(rows)} — "
-        f"likely a duplicate-span regression from bucket window expansion"
-    )
-    returned_span_ids = {r["data"]["span_id"] for r in rows}
-    assert returned_span_ids == {span_id_a, span_id_b}
-    assert all(r["data"]["trace_id"] == trace_id for r in rows)