htwkmooc/poseidon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix flaky TestNomadStderrFifoIsRemoved

Browse Source 
that expected only one allocation per job. However, in practice, a job can be rescheduled on multiple allocations.
This commit is contained in:
Maximilian Paß
2023-11-17 13:20:42 +01:00
parent 41eb2627ae
commit 4ce124fdab
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
tests/e2e/websocket_test.go
View File

@ -7,6 +7,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/gorilla/websocket" "github.com/gorilla/websocket"
"github.com/hashicorp/nomad/api"
"github.com/openHPI/poseidon/internal/nomad" "github.com/openHPI/poseidon/internal/nomad"
"github.com/openHPI/poseidon/pkg/dto" "github.com/openHPI/poseidon/pkg/dto"
"github.com/openHPI/poseidon/pkg/logging" "github.com/openHPI/poseidon/pkg/logging"
@ -324,8 +325,14 @@ func parseLogFile(t *testing.T, name string, start time.Time, end time.Time) (lo
func (s *E2ETestSuite) ListTempDirectory(runnerID string) string { func (s *E2ETestSuite) ListTempDirectory(runnerID string) string {
allocListStub, _, err := nomadClient.Jobs().Allocations(runnerID, true, nil) allocListStub, _, err := nomadClient.Jobs().Allocations(runnerID, true, nil)
s.Require().NoError(err) s.Require().NoError(err)
s.Require().Equal(1, len(allocListStub)) var runningAllocStub *api.AllocationListStub
alloc, _, err := nomadClient.Allocations().Info(allocListStub[0].ID, nil) for _, stub := range allocListStub {
if stub.ClientStatus == api.AllocClientStatusRunning && stub.DesiredStatus == api.AllocDesiredStatusRun {
runningAllocStub = stub
break
}
}
alloc, _, err := nomadClient.Allocations().Info(runningAllocStub.ID, nil)
s.Require().NoError(err) s.Require().NoError(err)
var stdout, stderr bytes.Buffer var stdout, stderr bytes.Buffer