1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
# Copyright The OpenTelemetry Authors
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
from __future__ import annotations
from logging import getLogger
from typing import Collection
from packaging.requirements import InvalidRequirement, Requirement
from opentelemetry.util._importlib_metadata import (
Distribution,
PackageNotFoundError,
version,
)
logger = getLogger(__name__)
class DependencyConflict:
required: str | None = None
found: str | None = None
def __init__(self, required: str | None, found: str | None = None):
self.required = required
self.found = found
def __str__(self):
return f'DependencyConflict: requested: "{self.required}" but found: "{self.found}"'
def get_dist_dependency_conflicts(
dist: Distribution,
) -> DependencyConflict | None:
instrumentation_deps = []
extra = "extra"
instruments = "instruments"
instruments_marker = {extra: instruments}
if dist.requires:
for dep in dist.requires:
if extra not in dep or instruments not in dep:
continue
req = Requirement(dep)
if req.marker.evaluate(instruments_marker):
instrumentation_deps.append(req)
return get_dependency_conflicts(instrumentation_deps)
def get_dependency_conflicts(
deps: Collection[str | Requirement],
) -> DependencyConflict | None:
for dep in deps:
if isinstance(dep, Requirement):
req = dep
else:
try:
req = Requirement(dep)
except InvalidRequirement as exc:
logger.warning(
'error parsing dependency, reporting as a conflict: "%s" - %s',
dep,
exc,
)
return DependencyConflict(dep)
try:
dist_version = version(req.name)
except PackageNotFoundError:
return DependencyConflict(dep)
if not req.specifier.contains(dist_version):
return DependencyConflict(dep, f"{req.name} {dist_version}")
return None
|
