fix: updates for tsdb blocks handling - #1928
Conversation
kakkoyun
left a comment
There was a problem hiding this comment.
Considering these issues slipped through the cracks, I would really appreciate if you could add more comprehensive tests so that we prevent similar future issues.
Thanks in advance 🙏
|
That's fair, I can expand tests. Ideally, it would be simpler to just import prometheus itself as a library and use the types already defined for these in prometheus. That would obviously help to keep things in sync and benefit from existing testing there. It becomes a bit awkward though, since prometheus itself also imports the client_golang library (mostly for implementing metrics) and so we'd be importing ourselves and nearing a circular import. It would also blow up dependencies, and I know this library is already heavily used/strictly watched for deps. Perhaps this is a situation where a little bit of copying is better than a little bit of dependency? |
60bdf9b to
d78b175
Compare
|
Both of the checks that are failing are for @kakkoyun sorry it's been a bit -- if you get some more time, I'd appreciate some fresh eyes please! |
68fb72f to
4765ce8
Compare
|
Both of the test failures in CI are for collectors/ and are unrelated to the changes here 👍 |
4765ce8 to
076f4ef
Compare
Cover the edge cases that let the original implementation gaps slip through, per review feedback on prometheus#1928: - empty and null `blocks` lists - a block with every optional stats/compaction field populated, including `parents` lineage - multiple blocks at different compaction levels - missing optional `stats` field deserializing to zero values - a `from-out-of-order` compaction hint (the literal upstream's CompactionHintFromOutOfOrder constant emits) - zero-value time boundaries and non-default `version` values All `inRes` payloads model the post-envelope body, matching what `apiClientImpl.Do()` actually hands to `TSDBBlocks()`. Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
076f4ef to
4d95e8b
Compare
I forgot the implementation for `*apiClientImpl.Do()` already extracts the response content from the enveloped `data` field in the response, so the wrapper struct isn't needed here. Aligns with the upstream `tsdb.BlockMeta` types, while also adding fields missed in the initial implementation and match upstream JSON tags exactly (notably `omitempty` on all stats fields and on sources) so re-marshaling these types produces the same wire format Prometheus emits. Note: This changes the public API surface and is a breaking change, now that 1.24.0 has been officially cut, so changelog has been updated as well. Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
Cover the edge cases that let the original implementation gaps slip through, per review feedback on prometheus#1928: - empty and null `blocks` lists - a block with every optional stats/compaction field populated, including `parents` lineage - multiple blocks at different compaction levels - missing optional `stats` field deserializing to zero values - a `from-out-of-order` compaction hint (the literal upstream's CompactionHintFromOutOfOrder constant emits) - zero-value time boundaries and non-default `version` values All `inRes` payloads model the post-envelope body, matching what `apiClientImpl.Do()` actually hands to `TSDBBlocks()`. Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
The v1 API TSDB block types are hand-copied from prometheus/prometheus (importing it from the main module would be near-circular, since Prometheus imports client_golang), so nothing ties them to upstream at compile time. Add a standalone test module, api/prometheus/v1/paritytest, that imports both and checks the client types against the real thing: - A wire test generates blocks with Prometheus's own BlockWriter and LeveledCompactor, serializes the metas like the /api/v1/status/tsdb/blocks handler does, and requires the client types to decode and re-marshal that payload into structurally identical JSON. A coverage guard ensures every optional field is actually exercised, so parity cannot pass vacuously. - A reflect-based check compares json tags field by field, catching added, removed, or renamed fields and omitempty drift that the wire test would miss when a new field is zero-valued on both sides. Mutation-tested: renaming a client tag fails both with field-level diffs. The separate module keeps prometheus/prometheus out of client_golang's module graph; it is a leaf, so consumers are unaffected. It replaces client_golang with the in-tree checkout and pins a prometheus release that dependabot bumps, so upstream type changes fail the parity test in the bump PR. Fixture code uses the ecosystem's own helpers (promslog.NewNopLogger, model.MetricNameLabel), hence prometheus/common as a direct requirement. test-parity is deliberately not part of `make test`: compiling the pinned Prometheus against the in-tree client_golang on every PR would couple all of CI to the pin, with incompatibilities surfacing as compile errors in third-party code on unrelated jobs. It runs as a dedicated path-filtered Parity workflow instead, plus a weekly job against prometheus@latest as a backstop in case dependabot never materializes a bump for the replace-containing module. The rationale for the path filters, the download-only parity-deps prerequisite, and the workflow's concurrency keying lives in the workflow and Makefile comments. Assisted-by: Claude Code:claude-fable-5 <noreply@anthropic.com> Co-Authored-By: Claude Fable 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01J5MigTnAXKqvqTBinW4nhz Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
4d95e8b to
df2c55a
Compare
Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
…etric Go 1.25.13 and 1.26.6 add the runtime/metrics entry /godebug/non-default-behavior/fips140ems:events, which the checked-in expected metric sets did not know about, so TestExpectedRuntimeMetrics, TestGoCollector_ExposedMetrics, and TestGoCollectorAllowList fail on every CI matrix job for every PR (CI tracks the newest patch release via check-latest). Same shape as prometheus#1962 for htmlmetacontenturlescape. Regenerated with each CI toolchain: ``` cd prometheus GOTOOLCHAIN=go1.26.6 go run -mod=mod gen_go_collector_metrics_set.go go1.26.6 GOTOOLCHAIN=go1.25.13 go run -mod=mod gen_go_collector_metrics_set.go go1.25.13 ``` (-mod=mod because the generator's hashicorp/go-version import is not in go.mod; the resulting go.mod/go.sum churn is discarded.) The hand-maintained allow lists in prometheus/collectors are updated to match. As with prometheus#1962, the tests now require the newest patch release of each supported minor; older patch toolchains fail them locally. Assisted-by: Claude Code:claude-fable-5 <noreply@anthropic.com> Co-Authored-By: Claude Fable 5 <noreply@anthropic.com> Signed-off-by: TJ Hoplock <t.hoplock@gmail.com>
|
@kakkoyun @bwplotka @ArthurSens would you mind taking a fresh look at this? Now that 1.24.x is out, this will be a breaking change. To the point about improving tests, in addition to the expanded test suite and edge cases covered I also used claude to help create a parity test -- its a separate test suite in a separate go mod that uses prometheus as a library with our upstream prom version's code and compares it against client_golang's counterparts. It also wires up a separate CI job to bump prometheus versions and fail loudly if the parity test fails. Thoughts? |
bwplotka
left a comment
There was a problem hiding this comment.
Thanks!
Maybe I am not used to not worrying about extra code in the AI era, but I would prefer we don't reimplement block creation or use internal Prometheus DB for niche API like TSDB block API that we didn't notice it was broken (:
I wonder if we can focus on long term testing for those things - for now I am ok to fix it and merge and figure out e2e testing later. There is also #1998 which is an interesting alternative.
If we really need testing, then I'd vote for reflection based solution only (diff of structs).
|
|
||
| // writeBlock writes a block with float and native histogram samples to | ||
| // dir and returns its ULID. | ||
| func writeBlock(t *testing.T, dir string, seed int64) ulid.ULID { |
There was a problem hiding this comment.
This is likely an overkill -- tons of complexity that can change anytime (Prom often adds breaking changes to those e.g. TSDB internal methods).
This will also not catch the other bug around "data" parsing.
Here it would be enough to compare if structs match (eg. .reflection) or even regenerate struct with some go generator and put that into a test, but instead I wonder - should we invest in using OpenAPI spec (PoC) instead?
| @@ -78,5 +78,4 @@ func TestAcceptance(t *testing.T) { | |||
| if gotErr { | |||
| fmt.Println("Got this response from ", fmt.Sprintf("http://localhost:%v", WhatsupPort), ":", metrics) | |||
There was a problem hiding this comment.
Let's minimize unrelated changes
| }, | ||
| }, | ||
|
|
||
| // Multiple blocks at different compaction levels. |
There was a problem hiding this comment.
Do we care about this case? Nothing changes from the API standpoint here - less tests to maintain the better
| }, | ||
| }, | ||
|
|
||
| // Null blocks field (server returns null instead of empty array). |
There was a problem hiding this comment.
Do we need to test Go unmarshalling here? We don't do this for other API endpoints.
| // expected literal below a compile error and the decode a | ||
| // truncation failure. | ||
| { | ||
| do: doTSDBBlocks(), |
There was a problem hiding this comment.
Can we have a single case that have all of those quirks? (CI time is important)
| }, | ||
| }, | ||
| "version": 1, | ||
| // Note: no "stats" field |
There was a problem hiding this comment.
Again, could be in one case if we want
| }, | ||
| }, | ||
|
|
||
| // Block with the compaction hint Prometheus's OOO feature emits |
| }, | ||
| }, | ||
|
|
||
| // Block with zero-value time boundaries (edge case). |
There was a problem hiding this comment.
Perhaps too much? Could be removed?
| }, | ||
| }, | ||
|
|
||
| // Block with different version values. |
There was a problem hiding this comment.
Again, not really changing anything - should be part of a single case
Two small fixes:
*apiClientImpl.Do()already extractsthe response content from the enveloped
datafield in the response,so the wrapper struct isn't needed here.
compactionsection of a block has an optionalparentsfieldfor tracking block lineage in deeper compaction levels. This slipped
my mind during implementation because I was looking at the example API
response on the API docs, which use a mock response with a single block
that is uncompacted.
I noticed these while working on prometheus/prometheus-mcp#77
Signed-off-by: TJ Hoplock t.hoplock@gmail.com