fix log message when fetching imps/events/uks fails

splitio · Jul 14, 2023 · c585ee5 · c585ee5
1 parent cf92e16
commit c585ee5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git 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
@@ -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: