From 72aeba89ec63b311594056af520e8f249bfeeaf4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Philip=20Dub=C3=A9?= <philip@peerdb.io>
Date: Tue, 21 May 2024 22:15:11 +0000
Subject: [PATCH] fix qvalue qrep

---
 flow/model/qrecord_copy_from_source.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flow/model/qrecord_copy_from_source.go b/flow/model/qrecord_copy_from_source.go
index f354549300..745827309c 100644
--- a/flow/model/qrecord_copy_from_source.go
+++ b/flow/model/qrecord_copy_from_source.go
@@ -42,7 +42,7 @@ func NewQRecordCopyFromSource(
 func (src *QRecordCopyFromSource) Next() bool {
 	rec, ok := <-src.stream.Records
 	src.currentRecord = rec
-	return ok && src.Err() != nil
+	return ok || src.Err() != nil
 }
 
 func (src *QRecordCopyFromSource) Values() ([]interface{}, error) {