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

client: unflake TestClient_ACL_ResolveToken_InvalidClaims (#25758)

Browse Source
This commit is contained in:
Piotr Kazmierczak
2025-04-25 14:53:09 +02:00
committed by GitHub
parent e928131482
commit 32ca833c70
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
client/acl_test.go
View File

@@ -4,6 +4,7 @@
package client
import (
"strings"
"testing"
"time"
@@ -17,6 +18,7 @@ import (
"github.com/hashicorp/nomad/testutil"
"github.com/shoenig/test"
"github.com/shoenig/test/must"
"github.com/shoenig/test/wait"
)
func Test_clientACLResolver_init(t *testing.T) {
@@ -367,8 +369,14 @@ func TestClient_ACL_ResolveToken_InvalidClaims(t *testing.T) {
allocs = testutil.WaitForJobAllocStatusWithToken(t, s1.RPC, job, cond, rootToken.SecretID)
must.Len(t, 1, allocs)
// ResolveToken should error now that alloc is dead
// ResolveToken should error now that alloc is dead, retry in case we hit a
// cache invalidation race
must.Wait(t, wait.InitialSuccess(
wait.BoolFunc(func() bool {
aclObj, err := c1.ResolveToken(wid)
must.ErrorContains(t, err, "allocation is terminal")
must.Nil(t, aclObj)
return aclObj == nil && strings.Contains(err.Error(), "allocation is terminal")
}),
wait.Timeout(time.Second*10),
wait.Gap(time.Millisecond*30),
))
}