c.Check(int(testutil.ToFloat64(sch.mLongestWaitTimeSinceQueue)), check.Equals, 0)
}
-// Assign priority=4 container to idle node. Create new instances for
-// the priority=3 and 1 containers. Ignore the supervisor at priority 2.
+// Assign priority=4, 3 and 1 containers to idle nodes. Ignore the supervisor at priority 2.
func (*SchedulerSuite) TestSkipSupervisors(c *check.C) {
ctx := ctxlog.Context(context.Background(), ctxlog.TestLogger(c))
queue := test.Queue{
VCPUs: 1,
RAM: 1 << 30,
},
- Command: []string{"arvados-cwl-runner"},
+ SchedulingParameters: arvados.SchedulingParameters{
+ Supervisor: true,
+ },
},
{
UUID: test.ContainerUUID(3),
VCPUs: 1,
RAM: 1 << 30,
},
- Command: []string{"arvados-cwl-runner"},
+ SchedulingParameters: arvados.SchedulingParameters{
+ Supervisor: true,
+ },
},
},
}