kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-07 19:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

spelling: enqueuing

Browse Source
This commit is contained in:
Josh Soref
2018-03-11 18:00:07 +00:00
parent 6a08900d07
commit ad26083c01
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
nomad/eval_broker.go
View File

@@ -210,7 +210,7 @@ func (b *EvalBroker) processEnqueue(eval *structs.Evaluation, token string) {
}
// processWaitingEnqueue waits the given duration on the evaluation before
// enqueueing.
// enqueuing.
func (b *EvalBroker) processWaitingEnqueue(eval *structs.Evaluation) {
timer := time.AfterFunc(eval.Wait, func() {
b.enqueueWaiting(eval)

2
nomad/eval_broker_test.go
View File

@@ -1140,7 +1140,7 @@ func TestEvalBroker_Wait(t *testing.T) {
}
}
// Ensure that priority is taken into account when enqueueing many evaluations.
// Ensure that priority is taken into account when enqueuing many evaluations.
func TestEvalBroker_EnqueueAll_Dequeue_Fair(t *testing.T) {
t.Parallel()
b := testBroker(t, 0)

2
nomad/eval_endpoint_test.go
View File

@@ -286,7 +286,7 @@ func TestEvalEndpoint_Dequeue_WaitIndex(t *testing.T) {
}
func TestEvalEndpoint_Dequeue_UpdateWaitIndex(t *testing.T) {
// test enqueueing an eval, updating a plan result for the same eval and de-queueing the eval
// test enqueuing an eval, updating a plan result for the same eval and de-queueing the eval
t.Parallel()
s1 := TestServer(t, func(c *Config) {
c.NumSchedulers = 0 // Prevent automatic dequeue