Skip to content

Commit c494b79

Browse files
authored
Merge pull request #1356 from elezar/update-for-spark
Ignore errors getting optional device attributes
2 parents 1bc2b15 + e3323ce commit c494b79

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

internal/lm/resource.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,8 @@ import (
2121
"regexp"
2222
"strings"
2323

24+
"k8s.io/klog/v2"
25+
2426
spec "github.com/NVIDIA/k8s-device-plugin/api/config/v1"
2527
"github.com/NVIDIA/k8s-device-plugin/internal/resource"
2628
)
@@ -46,7 +48,7 @@ func NewGPUResourceLabeler(config *spec.Config, device resource.Device, count in
4648

4749
totalMemoryMiB, err := device.GetTotalMemoryMiB()
4850
if err != nil {
49-
return nil, fmt.Errorf("failed to get memory info for device: %v", err)
51+
klog.Warningf("Ignoring error getting memory info for device: %v", err)
5052
}
5153

5254
resourceLabeler := newResourceLabeler(fullGPUResourceName, config)

internal/rm/devices.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ import (
2121
"strconv"
2222
"strings"
2323

24+
"k8s.io/klog/v2"
2425
pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1"
2526
)
2627

@@ -73,7 +74,7 @@ func BuildDevice(index string, d deviceInfo) (*Device, error) {
7374

7475
totalMemory, err := d.GetTotalMemory()
7576
if err != nil {
76-
return nil, fmt.Errorf("error getting device memory: %w", err)
77+
klog.Warningf("Ignoring error getting device memory: %v", err)
7778
}
7879

7980
computeCapability, err := d.GetComputeCapability()

0 commit comments

Comments
 (0)