Update
This commit is contained in:
2
frontend
2
frontend
Submodule frontend updated: 0d0b050d08...cb41918f9d
10
main.go
10
main.go
@@ -32,6 +32,12 @@ func main() {
|
||||
}
|
||||
|
||||
func DoIngest() {
|
||||
db, err := GetDB()
|
||||
if err != nil {
|
||||
logger.Error("Failed to get database: %v", err)
|
||||
return
|
||||
}
|
||||
|
||||
killmailFiles, err := os.ReadDir("data")
|
||||
if err != nil {
|
||||
logger.Error("Failed to read data directory: %v", err)
|
||||
@@ -43,7 +49,7 @@ func DoIngest() {
|
||||
filteredKillmailFiles = append(filteredKillmailFiles, file)
|
||||
}
|
||||
}
|
||||
filteredKillmailFiles = filteredKillmailFiles[:1] // DEBUG
|
||||
// filteredKillmailFiles = filteredKillmailFiles[:1] // DEBUG
|
||||
|
||||
totalFiles := len(filteredKillmailFiles)
|
||||
utils.WithWorkers(6, filteredKillmailFiles, func(worker int, index int, file os.DirEntry) {
|
||||
@@ -56,7 +62,7 @@ func DoIngest() {
|
||||
return
|
||||
}
|
||||
flog.Info("Loaded %d killmails", len(killmails))
|
||||
killmails = killmails[:1000] // DEBUG
|
||||
// killmails = killmails[:1000] // DEBUG
|
||||
// logger.Default.SetLevel(logger.LevelDebug)
|
||||
|
||||
FlatKillmails := []*FlatKillmail{}
|
||||
|
||||
Reference in New Issue
Block a user