luxolus/open-nomad
2
0
Fork 0
Code Issues 1 Pull requests Packages Releases Wiki Activity

e2e: csi: wait for volume write claims to be released before starting read jobs (#7641)

Browse source
This commit is contained in:
Lang Martin 2020-04-07 07:40:44 -04:00 committed by GitHub
parent b5104e5b6a
commit c0dbcbef5f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
e2e/csi/csi.go
View file

@ -110,7 +110,14 @@ func (tc *CSIVolumesTest) TestEBSVolumeClaim(f *framework.F) {
// racy. Once the unmount hang problem with -purge is fixed,
// we can restore this.
nomadClient.Jobs().Deregister(writeJobID, false, nil)
e2eutil.WaitForAllocStopped(t, nomadClient, writeAllocID)
// instead of waiting for the alloc to stop, wait for the volume claim gc run
require.Eventuallyf(func() bool {
vol, _, err := nomadClient.CSIVolumes().Info(volID, nil)
if err != nil {
return false
}
return len(vol.WriteAllocs) == 0
}, 90*time.Second, 5*time.Second, "write-ebs alloc claim was not released")
// deploy a job so we can read from the volume
readJobID := "read-ebs-" + uuid[0:8]
@ -184,7 +191,14 @@ func (tc *CSIVolumesTest) TestEFSVolumeClaim(f *framework.F) {
// does not.
// this runs the equivalent of 'nomad job stop'
nomadClient.Jobs().Deregister(writeJobID, false, nil)
e2eutil.WaitForAllocStopped(t, nomadClient, writeAllocID)
// instead of waiting for the alloc to stop, wait for the volume claim gc run
require.Eventuallyf(func() bool {
vol, _, err := nomadClient.CSIVolumes().Info(volID, nil)
if err != nil {
return false
}
return len(vol.WriteAllocs) == 0
}, 90*time.Second, 5*time.Second, "write-efs alloc claim was not released")
// deploy a job that reads from the volume.
readJobID := "read-efs-" + uuid[0:8]