trying to fix unit test

snowplow · Aug 29, 2022 · 420d2ca · 420d2ca
1 parent c6ffdad
commit 420d2ca
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/pkg/target/kinesis_test.go b/pkg/target/kinesis_test.go
@@ -8,6 +8,10 @@ package target
 
 import (
 	"fmt"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/credentials"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/kinesis"
 	"strings"
 	"sync/atomic"
 	"testing"
@@ -37,7 +41,12 @@ func TestKinesisTarget_KinesisConnectionFailure(t *testing.T) {
 
 	assert := assert.New(t)
 
-	client := testutil.GetAWSLocalstackKinesisClient()
+	client := kinesis.New(session.Must(session.NewSession(&aws.Config{
+		Credentials:      credentials.NewStaticCredentials("foo", "var", ""),
+		S3ForcePathStyle: aws.Bool(true),
+		Region:           aws.String(`wrong-region`),
+		Endpoint:         aws.String(`wrong-endpoint`),
+	})))
 
 	target, err := newKinesisTargetWithInterfaces(client, "00000000000", testutil.AWSLocalstackRegion, "not-exists")
 	assert.NotNil(err)