fix: log more in importer (#4909)

Log when it's done, and for each vuln sent to worker

Author: michaelkedar

go/cmd/importer/main.go

@@ -90,10 +90,12 @@ func main() {
 		if err := importer.RunDeletions(ctx, config); err != nil {
 			logger.FatalContext(ctx, "Importer-deleter failed", slog.Any("error", err))
 		}
+		logger.InfoContext(ctx, "Importer-deleter completed successfully")
 	} else {
 		if err := importer.Run(ctx, config); err != nil {
 			logger.FatalContext(ctx, "Importer failed", slog.Any("error", err))
 		}
+		logger.InfoContext(ctx, "Importer completed successfully")
 	}
 }
 

go/internal/importer/importer.go

@@ -313,8 +313,18 @@ func processUpdate(ctx context.Context, config Config, item WorkItem) {
 		}
 	}
 	if err := sendToWorker(ctx, config, item, hash, modified, &vulnProto); err != nil {
-		logger.ErrorContext(ctx, "Failed to send to worker", slog.Any("error", err), slog.String("source", sourceRepoName), slog.String("path", sourcePath))
+		logger.ErrorContext(ctx, "Failed to send to worker",
+			slog.Any("error", err),
+			slog.String("source", sourceRepoName),
+			slog.String("path", sourcePath),
+			slog.String("id", vulnProto.GetId()))
+
+		return
 	}
+	logger.InfoContext(ctx, "Sent to worker",
+		slog.String("source", sourceRepoName),
+		slog.String("path", sourcePath),
+		slog.String("id", vulnProto.GetId()))
 }
 
 func computeHash(data []byte) string {