bugfix: Allow for optional timeslicing configuration

This fixes a vestigial bug from the introduction of MPS. Now that two timeslicing configurations are available, it's possible for MPS to be configured instead of timeslicing.

But since the TimeSlicing field was made non-optional - its existence is forced when unmarshalling, and then the parsing fails because no resources are specified under the empty TimeSlicing field.

Signed-off-by: Daniel Kleinstein <daniel.kleinstein@gmail.com>

Author: danielkleinstein

api/config/v1/config.go

@@ -96,9 +96,13 @@ func DisableResourceNamingInConfig(logger logger, config *Config) {
 	config.Resources.MIGs = nil
 
 	// Disable renaming / device selection in Sharing.TimeSlicing.Resources
-	config.Sharing.TimeSlicing.disableResoureRenaming(logger, "timeSlicing")
+	if (config.sharing.TimeSlicing != nil) {
+		config.Sharing.TimeSlicing.disableResoureRenaming(logger, "timeSlicing")
+	}
 	// Disable renaming / device selection in Sharing.MPS.Resources
-	config.Sharing.MPS.disableResoureRenaming(logger, "mps")
+	if (config.Sharing.MPS != nil) {
+		config.Sharing.MPS.disableResoureRenaming(logger, "mps")
+	}
 }
 
 // parseConfig parses a config file as either YAML of JSON and unmarshals it into a Config struct.

api/config/v1/sharing.go

@@ -19,7 +19,7 @@ package v1
 // Sharing encapsulates the set of sharing strategies that are supported.
 type Sharing struct {
 	// TimeSlicing defines the set of replicas to be made for timeSlicing available resources.
-	TimeSlicing ReplicatedResources `json:"timeSlicing,omitempty" yaml:"timeSlicing,omitempty"`
+	TimeSlicing *ReplicatedResources `json:"timeSlicing,omitempty" yaml:"timeSlicing,omitempty"`
 	// MPS defines the set of replicas to be shared using MPS
 	MPS *ReplicatedResources `json:"mps,omitempty"         yaml:"mps,omitempty"`
 }
@@ -38,7 +38,7 @@ func (s *Sharing) SharingStrategy() SharingStrategy {
 		return SharingStrategyMPS
 	}
 
-	if s.TimeSlicing.isReplicated() {
+	if s.TimeSlicing != nil && s.TimeSlicing.isReplicated() {
 		return SharingStrategyTimeSlicing
 	}
 	return SharingStrategyNone
@@ -49,5 +49,5 @@ func (s *Sharing) ReplicatedResources() *ReplicatedResources {
 	if s.MPS != nil {
 		return s.MPS
 	}
-	return &s.TimeSlicing
+	return s.TimeSlicing
 }

internal/lm/mig-strategy_test.go

@@ -183,7 +183,7 @@ func TestMigStrategyNoneLabels(t *testing.T) {
 					},
 				},
 				Sharing: spec.Sharing{
-					TimeSlicing: tc.timeSlicing,
+					TimeSlicing: &tc.timeSlicing,
 				},
 			}
 

internal/lm/nvml_test.go

@@ -103,7 +103,7 @@ func TestSharingLabeler(t *testing.T) {
 			description: "config with timeslicing replicas",
 			config: &spec.Config{
 				Sharing: spec.Sharing{
-					TimeSlicing: spec.ReplicatedResources{
+					TimeSlicing: &spec.ReplicatedResources{
 						Resources: []spec.ReplicatedResource{
 							{
 								Replicas: 2,

internal/lm/resource_test.go

@@ -55,7 +55,7 @@ func TestGPUResourceLabeler(t *testing.T) {
 			description: "time-slicing ignores non-matching resource",
 			count:       1,
 			sharing: spec.Sharing{
-				TimeSlicing: spec.ReplicatedResources{
+				TimeSlicing: &spec.ReplicatedResources{
 					Resources: []spec.ReplicatedResource{
 						{
 							Name:     "nvidia.com/not-gpu",
@@ -79,7 +79,7 @@ func TestGPUResourceLabeler(t *testing.T) {
 			description: "time-slicing appends suffix and doubles count",
 			count:       1,
 			sharing: spec.Sharing{
-				TimeSlicing: spec.ReplicatedResources{
+				TimeSlicing: &spec.ReplicatedResources{
 					Resources: []spec.ReplicatedResource{
 						{
 							Name:     "nvidia.com/gpu",
@@ -103,7 +103,7 @@ func TestGPUResourceLabeler(t *testing.T) {
 			description: "time-slicing renamed does not append suffix and doubles count",
 			count:       1,
 			sharing: spec.Sharing{
-				TimeSlicing: spec.ReplicatedResources{
+				TimeSlicing: &spec.ReplicatedResources{
 					Resources: []spec.ReplicatedResource{
 						{
 							Name:     "nvidia.com/gpu",
@@ -422,7 +422,7 @@ func TestMigResourceLabeler(t *testing.T) {
 		t.Run(tc.description, func(t *testing.T) {
 			config := &spec.Config{
 				Sharing: spec.Sharing{
-					TimeSlicing: tc.timeSlicing,
+					TimeSlicing: &tc.timeSlicing,
 				},
 			}
 			l, err := NewMIGResourceLabeler(tc.resourceName, config, device, tc.count)

internal/rm/rm_test.go

@@ -53,7 +53,7 @@ func TestValidateRequest(t *testing.T) {
 		{
 			description: "timeslicing with single device",
 			sharing: spec.Sharing{
-				TimeSlicing: spec.ReplicatedResources{
+				TimeSlicing: &spec.ReplicatedResources{
 					Resources: []spec.ReplicatedResource{
 						{
 							Name:     "nvidia.com/gpu",
@@ -73,7 +73,7 @@ func TestValidateRequest(t *testing.T) {
 		{
 			description: "timeslicing with two devices",
 			sharing: spec.Sharing{
-				TimeSlicing: spec.ReplicatedResources{
+				TimeSlicing: &spec.ReplicatedResources{
 					Resources: []spec.ReplicatedResource{
 						{
 							Name:     "nvidia.com/gpu",
@@ -93,7 +93,7 @@ func TestValidateRequest(t *testing.T) {
 		{
 			description: "timeslicing with two devices -- failRequestsGreaterThanOne",
 			sharing: spec.Sharing{
-				TimeSlicing: spec.ReplicatedResources{
+				TimeSlicing: &spec.ReplicatedResources{
 					FailRequestsGreaterThanOne: true,
 					Resources: []spec.ReplicatedResource{
 						{