volume list ut fix (#931)

kanisterio · Mar 12, 2021 · cdd3716 · cdd3716
1 parent 500854f
commit cdd3716
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/pkg/blockstorage/awsebs/awsebs.go b/pkg/blockstorage/awsebs/awsebs.go
@@ -163,7 +163,7 @@ func (s *EbsStorage) VolumesList(ctx context.Context, tags map[string]string, zo
 	var fltrs []*ec2.Filter
 	dvi := &ec2.DescribeVolumesInput{}
 	for k, v := range tags {
-		fltr := ec2.Filter{Name: &k, Values: []*string{&v}}
+		fltr := ec2.Filter{Name: aws.String("tag:" + k), Values: []*string{&v}}
 		fltrs = append(fltrs, &fltr)
 	}
 

diff --git a/pkg/blockstorage/blockstorage_test.go b/pkg/blockstorage/blockstorage_test.go
@@ -195,13 +195,8 @@ func (s *BlockStorageProviderSuite) TestSnapshotCopy(c *C) {
 }
 
 func (s *BlockStorageProviderSuite) testVolumesList(c *C) {
-	var tags map[string]string
 	var zone string
-	if s.provider.Type() == blockstorage.TypeGPD {
-		tags = map[string]string{"name": "*"}
-	} else {
-		tags = map[string]string{"status": "available"}
-	}
+	tags := map[string]string{"testtag": "testtagvalue"}
 	zone = s.storageAZ
 	vols, err := s.provider.VolumesList(context.Background(), tags, zone)
 	c.Assert(err, IsNil)