From 650211556381cef63082fd39f9145426e9cbf993 Mon Sep 17 00:00:00 2001
From: dan <dan@ezoic.com>
Date: Fri, 3 Apr 2015 15:38:04 -0700
Subject: [PATCH] add recoverability in the pipeline, especially for throughput
 errors

---
 pipeline.go                    | 2 +-
 redshift_basic_emitter_test.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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