handle error

goccy · Apr 11, 2024 · 3c3d0c2 · 3c3d0c2
1 parent 2437402
commit 3c3d0c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/metadata/job.go b/internal/metadata/job.go
@@ -47,8 +47,8 @@ func (j *Job) Wait(ctx context.Context) (*internaltypes.QueryResponse, error) {
 	j.mu.Lock()
 	defer j.mu.Unlock()
 
-	if j.response != nil {
-		return j.response, nil
+	if j.response != nil || j.err != nil {
+		return j.response, j.err
 	}
 
 	ticker := time.NewTicker(100 * time.Millisecond)