diff --git a/splitio/commitversion.go b/splitio/commitversion.go
index e90e7a94..12a4c4b3 100644
--- a/splitio/commitversion.go
+++ b/splitio/commitversion.go
@@ -5,4 +5,4 @@ This file is created automatically, please do not edit
 */
 
 // CommitVersion is the version of the last commit previous to release
-const CommitVersion = "5d527e7"
+const CommitVersion = "cf92e16"
diff --git a/splitio/producer/task/pipelined.go b/splitio/producer/task/pipelined.go
index cbb3c71a..3a54f5ac 100644
--- a/splitio/producer/task/pipelined.go
+++ b/splitio/producer/task/pipelined.go
@@ -165,6 +165,10 @@ func (p *PipelinedSyncTask) filler() {
 	for p.running.IsSet() {
 		timer.Reset(1 * time.Second)
 		raw, err := p.worker.Fetch()
+		if err != nil {
+			p.logger.Error(fmt.Sprintf("[pipelined/%s] fetch function returned error: %s", p.name, err))
+		}
+
 		if len(raw) == 0 {
 			select {
 			case <-timer.C:
@@ -174,11 +178,6 @@ func (p *PipelinedSyncTask) filler() {
 				return
 			}
 		}
-		if err != nil {
-			p.logger.Error(fmt.Sprintf("[pipelined/%s] fetch function returned error: %s", p.name, err))
-			continue
-		}
-
 		howMany := len(raw)
 		select {
 		case p.inputBuffer <- raw: