From e0752ed59fe9a090cfa547d7c4c6e1d90e9f67dc Mon Sep 17 00:00:00 2001 From: iwanghc Date: Mon, 20 Jan 2025 19:06:57 +0800 Subject: [PATCH] fix: scannerd go test, add error nil judgment --- sqle/cmd/scannerd/scanners/supervisor/supervisor.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/sqle/cmd/scannerd/scanners/supervisor/supervisor.go b/sqle/cmd/scannerd/scanners/supervisor/supervisor.go index 8cb6859d5..e84d59eff 100644 --- a/sqle/cmd/scannerd/scanners/supervisor/supervisor.go +++ b/sqle/cmd/scannerd/scanners/supervisor/supervisor.go @@ -29,9 +29,11 @@ func Start(ctx context.Context, scanner scanners.Scanner, leastPushSecond, pushB for { select { case err := <-runErrCh: - UploadErr := scanner.Upload(context.TODO(), batch, err.Error()) - if UploadErr != nil { - return errors.Wrap(UploadErr, "failed to upload sql") + if err != nil { + UploadErr := scanner.Upload(context.TODO(), batch, err.Error()) + if UploadErr != nil { + return errors.Wrap(UploadErr, "failed to upload sql") + } } return err