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/bsp/util_rules/resources.py

1	# Copyright 2022 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	import logging	×
UNCOV 6	from collections import defaultdict	×
UNCOV 7	from collections.abc import Sequence	×
UNCOV 8	from dataclasses import dataclass	×
UNCOV 9	from typing import TypeVar	×
10
UNCOV 11	from pants.bsp.protocol import BSPHandlerMapping	×
UNCOV 12	from pants.bsp.spec.resources import ResourcesItem, ResourcesParams, ResourcesResult	×
UNCOV 13	from pants.bsp.util_rules.targets import (	×
14	BSPBuildTargetInternal,
15	BSPResourcesRequest,
16	BSPResourcesResult,
17	get_bsp_resources,
18	resolve_bsp_build_target_addresses,
19	resolve_bsp_build_target_identifier,
20	)
UNCOV 21	from pants.engine.fs import Workspace	×
UNCOV 22	from pants.engine.internals.native_engine import EMPTY_DIGEST, MergeDigests	×
UNCOV 23	from pants.engine.internals.selectors import concurrently	×
UNCOV 24	from pants.engine.intrinsics import merge_digests	×
UNCOV 25	from pants.engine.rules import _uncacheable_rule, collect_rules, implicitly, rule	×
UNCOV 26	from pants.engine.target import FieldSet	×
UNCOV 27	from pants.engine.unions import UnionMembership, UnionRule	×
28
UNCOV 29	_logger = logging.getLogger(__name__)	×
30
UNCOV 31	_FS = TypeVar("_FS", bound=FieldSet)	×
32
33
UNCOV 34	class ResourcesRequestHandlerMapping(BSPHandlerMapping):	×
UNCOV 35	method_name = "buildTarget/resources"	×
UNCOV 36	request_type = ResourcesParams	×
UNCOV 37	response_type = ResourcesResult	×
38
39
UNCOV 40	@dataclass(frozen=True)	×
UNCOV 41	class ResourcesForOneBSPTargetRequest:	×
UNCOV 42	bsp_target: BSPBuildTargetInternal	×
43
44
UNCOV 45	@rule	×
UNCOV 46	async def resources_bsp_target(	×
47	request: ResourcesForOneBSPTargetRequest,
48	union_membership: UnionMembership,
49	) -> BSPResourcesResult:
50	targets = await resolve_bsp_build_target_addresses(request.bsp_target, **implicitly())	×
51	resources_request_types: Sequence[type[BSPResourcesRequest]] = union_membership.get(	×
52	BSPResourcesRequest
53	)
54	field_sets_by_request_type: dict[type[BSPResourcesRequest], set[FieldSet]] = defaultdict(set)	×
55	for target in targets:	×
56	for resources_request_type in resources_request_types:	×
57	field_set_type = resources_request_type.field_set_type	×
58	if field_set_type.is_applicable(target):	×
59	field_set = field_set_type.create(target)	×
60	field_sets_by_request_type[resources_request_type].add(field_set)	×
61
62	resources_results = await concurrently(	×
63	get_bsp_resources(
64	**implicitly(
65	{
66	resources_request_type(
67	bsp_target=request.bsp_target, field_sets=tuple(field_sets)
68	): BSPResourcesRequest
69	}
70	)
71	)
72	for resources_request_type, field_sets in field_sets_by_request_type.items()
73	)
74
75	resources = tuple(sorted({resource for rr in resources_results for resource in rr.resources}))	×
76
77	output_digest = await merge_digests(	×
78	MergeDigests([rr.output_digest for rr in resources_results])
79	)
80
81	return BSPResourcesResult(	×
82	resources=resources,
83	output_digest=output_digest,
84	)
85
86
UNCOV 87	@_uncacheable_rule	×
UNCOV 88	async def bsp_resources_request(	×
89	request: ResourcesParams,
90	workspace: Workspace,
91	) -> ResourcesResult:
92	bsp_targets = await concurrently(	×
93	resolve_bsp_build_target_identifier(bsp_target_id, **implicitly())
94	for bsp_target_id in request.targets
95	)
96
97	resources_results = await concurrently(	×
98	resources_bsp_target(
99	ResourcesForOneBSPTargetRequest(
100	bsp_target=bsp_target,
101	),
102	**implicitly(),
103	)
104	for bsp_target in bsp_targets
105	)
106
107	# TODO: Need to determine how resources are expected to be exposed. Directories? Individual files?
108	# Initially, it looks like loose directories.
109	output_digest = await merge_digests(MergeDigests([r.output_digest for r in resources_results]))	×
110	if output_digest != EMPTY_DIGEST:	×
111	workspace.write_digest(output_digest, path_prefix=".pants.d/bsp")	×
112
113	return ResourcesResult(	×
114	tuple(
115	ResourcesItem(
116	target,
117	rr.resources,
118	)
119	for target, rr in zip(request.targets, resources_results)
120	)
121	)
122
123
UNCOV 124	def rules():	×
UNCOV 125	return (	×
126	*collect_rules(),
127	UnionRule(BSPHandlerMapping, ResourcesRequestHandlerMapping),
128	)

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