report errors from primary task

FGasper · FGasper · commit 12009283d415 · 2024-11-01T09:45:03.000-04:00
diff --git a/internal/verifier/check.go b/internal/verifier/check.go
@@ -290,7 +290,7 @@ func (verifier *Verifier) CreateInitialTasks(ctx context.Context) error {
 		}
 	}
 
-	verifier.doInMetaTransaction(
+	err := verifier.doInMetaTransaction(
 		ctx,
 		func(sctx mongo.SessionContext) error {
 			isPrimary, err := verifier.CheckIsPrimary(ctx)
@@ -325,6 +325,10 @@ func (verifier *Verifier) CreateInitialTasks(ctx context.Context) error {
 		},
 	)
 
+	if err != nil {
+		verifier.logger.Fatal().Err(err).Send()
+	}
+
 	return nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -290,7 +290,7 @@ func (verifier *Verifier) CreateInitialTasks(ctx context.Context) error {`
`290`	`290`	`}`
`291`	`291`	`}`
`292`	`292`
`293`		`- verifier.doInMetaTransaction(`
	`293`	`+ err := verifier.doInMetaTransaction(`
`294`	`294`	`ctx,`
`295`	`295`	`func(sctx mongo.SessionContext) error {`
`296`	`296`	`isPrimary, err := verifier.CheckIsPrimary(ctx)`
`@@ -325,6 +325,10 @@ func (verifier *Verifier) CreateInitialTasks(ctx context.Context) error {`
`325`	`325`	`},`
`326`	`326`	`)`
`327`	`327`
	`328`	`+ if err != nil {`
	`329`	`+ verifier.logger.Fatal().Err(err).Send()`
	`330`	`+ }`
	`331`	`+`
`328`	`332`	`return nil`
`329`	`333`	`}`
`330`	`334`