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

Update tests after moving idempotency token to WriteOptions

Browse Source
This commit is contained in:
Alex Munda
2021-07-01 08:48:57 -05:00
parent 63d8e92e90
commit aa3512d11c
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
nomad/job_endpoint_test.go
View File

@@ -6133,9 +6133,6 @@ func TestJobEndpoint_Dispatch(t *testing.T) {
reqInputDataTooLarge := &structs.JobDispatchRequest{
Payload: make([]byte, DispatchPayloadSizeLimit+100),
}
reqIdempotentToken := &structs.JobDispatchRequest{
IdempotencyToken: "foo",
}
type existingIdempotentChildJob struct {
isTerminal bool
@@ -6148,6 +6145,7 @@ func TestJobEndpoint_Dispatch(t *testing.T) {
noEval bool
err bool
errStr string
idempotencyToken string
existingIdempotentJob *existingIdempotentChildJob
}
cases := []testCase{
@@ -6244,16 +6242,18 @@ func TestJobEndpoint_Dispatch(t *testing.T) {
{
name: "idempotency token, no existing child job",
parameterizedJob: d1,
dispatchReq: reqIdempotentToken,
dispatchReq: reqInputDataNoMeta,
err: false,
idempotencyToken: "foo",
existingIdempotentJob: nil,
},
{
name: "idempotency token, w/ existing non-terminal child job",
parameterizedJob: d1,
dispatchReq: reqIdempotentToken,
dispatchReq: reqInputDataNoMeta,
err: true,
errStr: "dispatch violates idempotency token of non-terminal child job",
errStr: "idempotent dispatch failed: another child job with this token is running or pending",
idempotencyToken: "foo",
existingIdempotentJob: &existingIdempotentChildJob{
isTerminal: false,
},
@@ -6261,8 +6261,9 @@ func TestJobEndpoint_Dispatch(t *testing.T) {
{
name: "idempotency token, w/ existing terminal job",
parameterizedJob: d1,
dispatchReq: reqIdempotentToken,
dispatchReq: reqInputDataNoMeta,
err: false,
idempotencyToken: "foo",
existingIdempotentJob: &existingIdempotentChildJob{
isTerminal: true,
},
@@ -6296,8 +6297,9 @@ func TestJobEndpoint_Dispatch(t *testing.T) {
// Now try to dispatch
tc.dispatchReq.JobID = tc.parameterizedJob.ID
tc.dispatchReq.WriteRequest = structs.WriteRequest{
Region: "global",
Namespace: tc.parameterizedJob.Namespace,
Region: "global",
Namespace: tc.parameterizedJob.Namespace,
IdempotencyToken: tc.idempotencyToken,
}
// Dispatch with the same request so a child job w/ the idempotency key exists