Skip to content

Commit

Permalink
fix: disable influxdb (#94)
Browse files Browse the repository at this point in the history
Co-authored-by: mulmuri <gyumin.oh@payhere.in>
  • Loading branch information
mulmuri and mulmuri authored Feb 20, 2025
1 parent 3318f83 commit d54a7d0
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
1 change: 0 additions & 1 deletion cmd/dbiniter/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ import (
)

func main() {
log.SetLevel(log.InfoLevel)
log.Info("Application started")

ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
Expand Down
11 changes: 6 additions & 5 deletions cmd/preparer/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ import (
)

func main() {
log.SetLevel(log.InfoLevel)
log.Info("Application started")

ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
Expand All @@ -26,14 +25,16 @@ func main() {
}
defer cleanup()

topics, err := preparer.SyncETCDToDB(ctx)
_, err = preparer.SyncETCDToDB(ctx)
if err != nil {
log.Panic(errors.Wrap(err, "Failed to synchronize etcd to db"))
}

if err := preparer.PrepareTopics(ctx, topics); err != nil {
log.Panic(errors.Wrap(err, "Failed to prepare topics"))
}
/*
if err := preparer.PrepareTopics(ctx, topics); err != nil {
log.Panic(errors.Wrap(err, "Failed to prepare topics"))
}
*/

log.Info("Application successfully finished")
}

0 comments on commit d54a7d0

Please # to comment.