+ "query": "from(bucket: \"benchmarks-telemetry\")\n |> range(start: v.timeRangeStart, stop: v.timeRangeStop)\n |> filter(fn: (r) => r[\"type\"] == \"spicebench\")\n |> filter(fn: (r) => r[\"_measurement\"] == \"query_queue_duration_ms\")\n |> filter(fn: (r) => exists r[\"adapter_name\"])\n |> filter(fn: (r) => r[\"scenario\"] =~ /^${scenario:regex}$/)\n |> filter(fn: (r) => r[\"scale_factor\"] =~ /^${scale_factor:regex}$/)\n |> filter(fn: (r) => \"${outcome}\" == \"All\" or (exists r[\"outcome\"] and r[\"outcome\"] == \"${outcome}\"))\n |> filter(fn: (r) => r[\"_field\"] != \"count\" and r[\"_field\"] != \"sum\")\n |> toFloat()\n |> map(fn: (r) => ({\n r with\n le: if r[\"_field\"] == \"+Inf\" then 10000000.0 else float(v: r[\"_field\"])\n }))\n |> group(columns: [\"adapter_name\", \"scenario\", \"scale_factor\", \"_time\", \"le\"])\n |> sum()\n |> group(columns: [\"adapter_name\", \"scenario\", \"scale_factor\", \"_time\"])\n |> sort(columns: [\"le\"])\n |> cumulativeSum()\n |> histogramQuantile(quantile: 0.99)\n |> map(fn: (r) => ({r with legend: r[\"adapter_name\"] + \" - \" + r[\"scenario\"]}))\n |> group(columns: [\"legend\"])\n |> sort(columns: [\"_time\"])\n |> keep(columns: [\"_time\", \"_value\", \"legend\"])",
0 commit comments