add recoverability in the pipeline, especially for throughput errors

pipeline.go

@@ -33,7 +33,7 @@ func (p Pipeline) isRecoverableError(err error) bool {
 		r = true
 	}
 
-	return true
+	return r
 }
 
 // handle the aws exponential backoff

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 ',';"