reverting err message change in kinesis source to create it's own commit

snowplow · Aug 26, 2022 · e12d862 · e12d862
1 parent fb5670b
commit e12d862
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/source/kinesis/kinesis_source.go b/pkg/source/kinesis/kinesis_source.go
@@ -269,7 +269,7 @@ func (ks *kinesisSource) Read(sf *sourceiface.SourceFunctions) error {
 	case <-time.After(10 * time.Second):
 		// Append errors and crash
 		multierror.Append(kinesisPullErr, errors.Errorf("wg.Wait() took too long, forcing app close."))
-		ks.log.WithFields(log.Fields{"error": kinesisPullErr}).Fatal(kinesisPullErr)
+		ks.log.WithFields(log.Fields{"error": err}).Fatal(err)
 	}
 
 	// Return kinesisPullErr if we have one

diff --git a/pkg/source/sqs/sqs_source_test.go b/pkg/source/sqs/sqs_source_test.go
@@ -67,7 +67,7 @@ func TestNewSQSSourceWithInterfaces_Success(t *testing.T) {
 }
 
 // newSQSSourceWithInterfaces should fail if we can't reach SQS
-func TestNewSQSSourceWithInterfaces_SQSConnectioNFailure(t *testing.T) {
+func TestNewSQSSourceWithInterfaces_SQSConnectionFailure(t *testing.T) {
 	// Unlike the success test, we don't require anything to exist for this one
 	assert := assert.New(t)