small comment fix

Author: TiganeteaRobert

pkg/source/sqs/sqs_source_test.go

@@ -30,6 +30,20 @@ func TestMain(m *testing.M) {
 	os.Exit(exitVal)
 }
 
+// TestNewSqsSource_ConnectionCheck tests that the SQS source fails on start-up if the connection to SQS fails
+func TestNewSqsSource_ConnectionCheck(t *testing.T) {
+	assert := assert.New(t)
+
+	target, err := configFunction(&configuration{
+		QueueName:        "not-exists",
+		Region:           testutil.AWSLocalstackRegion,
+		RoleARN:          `arn:aws:sqs:us-east-1:00000000000:not-exists`,
+		ConcurrentWrites: 15,
+	})
+	assert.Nil(target)
+	assert.EqualError(err, "NoCredentialProviders: no valid providers in chain. Deprecated.\n\tFor verbose messaging see aws.Config.CredentialsChainVerboseErrors")
+}
+
 // func newSQSSourceWithInterfaces(client sqsiface.SQSAPI, awsAccountID string, concurrentWrites int, region string, queueName string) (*sqsSource, error) {
 func TestNewSQSSourceWithInterfaces_Success(t *testing.T) {
 	if testing.Short() {

pkg/target/eventhub_test.go

@@ -396,8 +396,7 @@ func TestNewEventHubTarget_ConnVarsErr(t *testing.T) {
 	assert.Nil(tgt)
 }
 
-// NewEventHubTarget should fail if we can't reach EventHub, commented out this test until we look into https://github.com/snowplow-devops/stream-replicator/issues/151
-// Note that when we do so, the above tests will need to be changed to use some kind of mock
+// NewEventHubTarget should fail if we can't reach EventHub
 func TestNewEventHubTarget_NoVars(t *testing.T) {
 	assert := assert.New(t)
 	// Test that we can initialise a client with Key and Value