Update check.go

tdq45gj · tdq45gj · commit f14962fdaf71 · 2024-11-27T18:36:54.000-05:00
diff --git a/internal/verifier/check.go b/internal/verifier/check.go
@@ -294,7 +294,9 @@ func (verifier *Verifier) CheckDriver(ctx context.Context, filter map[string]any
 			if err = verifier.waitForChangeStream(ctx, verifier.dstChangeStreamReader); err != nil {
 				return err
 			}
-			ceHandlerGroup.Wait()
+			if err = ceHandlerGroup.Wait(); err != nil {
+				return err
+			}
 			verifier.mux.Lock()
 			verifier.lastGeneration = true
 		}

Original file line number	Diff line number	Diff line change
`@@ -294,7 +294,9 @@ func (verifier *Verifier) CheckDriver(ctx context.Context, filter map[string]any`
`294`	`294`	`if err = verifier.waitForChangeStream(ctx, verifier.dstChangeStreamReader); err != nil {`
`295`	`295`	`return err`
`296`	`296`	`}`
`297`		`- ceHandlerGroup.Wait()`
	`297`	`+ if err = ceHandlerGroup.Wait(); err != nil {`
	`298`	`+ return err`
	`299`	`+ }`
`298`	`300`	`verifier.mux.Lock()`
`299`	`301`	`verifier.lastGeneration = true`
`300`	`302`	`}`