19015773527

Committed 02 Nov 2025 05:33PM UTC coverage: 17.872% (-62.4%) from 80.3%

Build # 19015773527

Build Type

Pull #22816

github

Committed by

web-flow

Commit Message

Merge a12d75757 into 6c024e162

Pull Request Pull Request #22816: Update Pants internal Python to 3.14

Run Details

4 of 5 new or added lines in 3 files covered. (80.0%)

28452 existing lines in 683 files now uncovered.

9831 of 55007 relevant lines covered (17.87%)

0.18 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/python/pants/backend/openapi/util_rules/openapi_bundle.py

1	# Copyright 2024 Pants project contributors (see CONTRIBUTORS.md).
2	# Licensed under the Apache License, Version 2.0 (see LICENSE).
UNCOV 3	from __future__ import annotations	×
4
UNCOV 5	from dataclasses import dataclass	×
UNCOV 6	from pathlib import PurePath	×
7
UNCOV 8	from pants.backend.javascript.subsystems import nodejs_tool	×
UNCOV 9	from pants.backend.javascript.subsystems.nodejs_tool import NodeJSToolRequest	×
UNCOV 10	from pants.backend.openapi.subsystems.redocly import Redocly	×
UNCOV 11	from pants.backend.openapi.target_types import (	×
12	OpenApiBundleDummySourceField,
13	OpenApiBundleSourceRootField,
14	OpenApiDocumentField,
15	OpenApiSourceField,
16	)
UNCOV 17	from pants.core.target_types import ResourceSourceField	×
UNCOV 18	from pants.core.util_rules.source_files import SourceFilesRequest	×
UNCOV 19	from pants.core.util_rules.stripped_source_files import strip_source_roots	×
UNCOV 20	from pants.engine.internals.graph import resolve_targets	×
UNCOV 21	from pants.engine.internals.graph import transitive_targets as transitive_targets_get	×
UNCOV 22	from pants.engine.internals.native_engine import AddPrefix, Digest, MergeDigests	×
UNCOV 23	from pants.engine.internals.selectors import concurrently	×
UNCOV 24	from pants.engine.intrinsics import add_prefix, digest_to_snapshot	×
UNCOV 25	from pants.engine.process import fallible_to_exec_result_or_raise	×
UNCOV 26	from pants.engine.rules import collect_rules, implicitly, rule	×
UNCOV 27	from pants.engine.target import (	×
28	Dependencies,
29	DependenciesRequest,
30	GeneratedSources,
31	GenerateSourcesRequest,
32	Target,
33	TransitiveTargetsRequest,
34	)
UNCOV 35	from pants.engine.unions import UnionRule	×
UNCOV 36	from pants.source.source_root import SourceRootRequest, get_source_root	×
UNCOV 37	from pants.util.logging import LogLevel	×
UNCOV 38	from pants.util.strutil import pluralize	×
39
40
UNCOV 41	class GenerateOpenApiBundleRequest(GenerateSourcesRequest):	×
UNCOV 42	input = OpenApiBundleDummySourceField	×
UNCOV 43	output = ResourceSourceField	×
44
45
UNCOV 46	@dataclass(frozen=True)	×
UNCOV 47	class _BundleOpenApiDocument:	×
UNCOV 48	target: Target	×
UNCOV 49	bundle_source_root: str \| None	×
50
51
UNCOV 52	@rule	×
UNCOV 53	async def bundle_openapi_document(request: _BundleOpenApiDocument, redocly: Redocly) -> Digest:	×
54	transitive_targets = await transitive_targets_get(	×
55	TransitiveTargetsRequest([request.target.address]), **implicitly()
56	)
57
58	source_root_request = get_source_root(	×
59	SourceRootRequest(PurePath(request.bundle_source_root))
60	if request.bundle_source_root
61	else SourceRootRequest.for_target(request.target)
62	)
63
64	target_stripped_sources_request = strip_source_roots(	×
65	**implicitly(SourceFilesRequest([request.target[OpenApiDocumentField]]))
66	)
67	all_stripped_sources_request = strip_source_roots(	×
68	**implicitly(
69	SourceFilesRequest(
70	tgt[OpenApiSourceField]
71	for tgt in transitive_targets.closure
72	if tgt.has_field(OpenApiSourceField)
73	)
74	)
75	)
76
77	source_root, target_stripped_sources, all_stripped_sources = await concurrently(	×
78	source_root_request,
79	target_stripped_sources_request,
80	all_stripped_sources_request,
81	)
82
83	result = await fallible_to_exec_result_or_raise(	×
84	**implicitly(
85	{
86	redocly.request(
87	args=(
88	"bundle",
89	target_stripped_sources.snapshot.files[0],
90	"-o",
91	target_stripped_sources.snapshot.files[0],
92	),
93	input_digest=all_stripped_sources.snapshot.digest,
94	output_files=(target_stripped_sources.snapshot.files[0],),
95	description=f"Run redocly on {pluralize(len(target_stripped_sources.snapshot.files), 'file')}.",
96	level=LogLevel.DEBUG,
97	): NodeJSToolRequest
98	}
99	)
100	)
101
102	source_root_restored = (	×
103	await add_prefix(AddPrefix(result.output_digest, source_root.path))
104	if source_root.path != "."
105	else result.output_digest
106	)
107	return source_root_restored	×
108
109
UNCOV 110	@rule	×
UNCOV 111	async def generate_openapi_bundle_sources(	×
112	request: GenerateOpenApiBundleRequest,
113	) -> GeneratedSources:
114	bundle_source_root = request.protocol_target[OpenApiBundleSourceRootField].value	×
115	openapi_document_targets = await resolve_targets(	×
116	**implicitly(DependenciesRequest(request.protocol_target[Dependencies]))
117	)
118	bundled_documents_digests = await concurrently(	×
119	bundle_openapi_document(_BundleOpenApiDocument(tgt, bundle_source_root), **implicitly())
120	for tgt in openapi_document_targets
121	if tgt.has_field(OpenApiDocumentField)
122	)
123	snapshot = await digest_to_snapshot(**implicitly(MergeDigests(bundled_documents_digests)))	×
124	return GeneratedSources(snapshot)	×
125
126
UNCOV 127	def rules():	×
UNCOV 128	return (	×
129	*collect_rules(),
130	*nodejs_tool.rules(),
131	UnionRule(GenerateSourcesRequest, GenerateOpenApiBundleRequest),
132	)

pantsbuild / pants / 19015773527

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous