ridv/gorealis
1
0
Fork 0
Code Issues Pull requests Projects Releases 23 Packages Wiki Activity Actions

Fixing tests

Browse source
This commit is contained in:
Renán Del Valle 2021-04-30 11:21:12 -07:00
parent 085bc39c50
commit d74833ac2b
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
1 changed files with 7 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

16
realis_e2e_test.go
View file

@ -211,7 +211,7 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
InstanceCount(2). InstanceCount(2).
AddPorts(1) AddPorts(1)
_, err := r.CreateJob(job) err := r.CreateJob(job)
require.NoError(t, err) require.NoError(t, err)
// Test Instances Monitor // Test Instances Monitor
@ -296,7 +296,7 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
AddLabel("hostname", "chips"). AddLabel("hostname", "chips").
AddLabel("chips", "chips") AddLabel("chips", "chips")
_, err := r.CreateJob(job) err := r.CreateJob(job)
require.NoError(t, err) require.NoError(t, err)
success, err := monitor.Instances(job.JobKey(), 2, 1, 50) success, err := monitor.Instances(job.JobKey(), 2, 1, 50)
@ -313,7 +313,7 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
AddValueConstraint("zone", false, "east"). AddValueConstraint("zone", false, "east").
AddValueConstraint("zone", true, "west") AddValueConstraint("zone", true, "west")
_, err := r.CreateJob(job) err := r.CreateJob(job)
require.NoError(t, err) require.NoError(t, err)
success, err := monitor.Instances(job.JobKey(), 2, 1, 50) success, err := monitor.Instances(job.JobKey(), 2, 1, 50)
@ -330,7 +330,7 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
AddValueConstraint("zone", true, "west", "east"). AddValueConstraint("zone", true, "west", "east").
AddLimitConstraint("zone", 2) AddLimitConstraint("zone", 2)
_, err := r.CreateJob(job) err := r.CreateJob(job)
require.NoError(t, err) require.NoError(t, err)
success, err := monitor.Instances(job.JobKey(), 2, 1, 50) success, err := monitor.Instances(job.JobKey(), 2, 1, 50)
@ -356,9 +356,8 @@ func TestRealisClient_CreateJob_ExecutorDoesNotExist(t *testing.T) {
Disk(10). Disk(10).
InstanceCount(1) InstanceCount(1)
resp, err := r.CreateJob(job) err := r.CreateJob(job)
assert.Error(t, err) assert.Error(t, err)
assert.Equal(t, aurora.ResponseCode_INVALID_REQUEST, resp.GetResponseCode())
} }
// Test configuring an executor that doesn't exist for CreateJob API // Test configuring an executor that doesn't exist for CreateJob API
@ -380,9 +379,8 @@ func TestRealisClient_GetPendingReason(t *testing.T) {
Disk(100). Disk(100).
InstanceCount(1) InstanceCount(1)
resp, err := r.CreateJob(job) err := r.CreateJob(job)
require.NoError(t, err) require.NoError(t, err)
assert.Equal(t, aurora.ResponseCode_OK, resp.ResponseCode)
taskQ := &aurora.TaskQuery{ taskQ := &aurora.TaskQuery{
Role: &role, Role: &role,
@ -767,7 +765,7 @@ func TestRealisClient_SessionThreadSafety(t *testing.T) {
Disk(10). Disk(10).
InstanceCount(1000) // Impossible amount to go live in any sane machine InstanceCount(1000) // Impossible amount to go live in any sane machine
_, err := r.CreateJob(job) err := r.CreateJob(job)
assert.NoError(t, err) assert.NoError(t, err)
wg := sync.WaitGroup{} wg := sync.WaitGroup{}