diff --git a/pipeline.go b/pipeline.go
index f6b6fb2..45ed981 100644
--- a/pipeline.go
+++ b/pipeline.go
@@ -33,7 +33,7 @@ func (p Pipeline) isRecoverableError(err error) bool {
 		r = true
 	}
 
-	return true
+	return r
 }
 
 // handle the aws exponential backoff
diff --git a/redshift_basic_emitter_test.go b/redshift_basic_emitter_test.go
index 7d993a1..a93d0f4 100644
--- a/redshift_basic_emitter_test.go
+++ b/redshift_basic_emitter_test.go
@@ -10,7 +10,7 @@ func TestCopyStatement(t *testing.T) {
 		S3Bucket:  "test_bucket",
 		TableName: "test_table",
 	}
-	f := e.copyStatement("/test.txt")
+	f := e.copyStatement("test.txt")
 
 	copyStatement := "COPY test_table FROM 's3://test_bucket/test.txt' CREDENTIALS 'aws_access_key_id=;aws_secret_access_key=' DELIMITER ',';"