Skip to content

Commit 8571010

Browse files
committed
minor change
1 parent 53f1895 commit 8571010

1 file changed

Lines changed: 0 additions & 12 deletions

File tree

cmd/committer.go

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -7,31 +7,19 @@ import (
77
"github.com/prometheus/client_golang/prometheus/promhttp"
88
"github.com/rs/zerolog/log"
99
"github.com/spf13/cobra"
10-
config "github.com/thirdweb-dev/indexer/configs"
1110
"github.com/thirdweb-dev/indexer/internal/committer"
1211
)
1312

14-
var committerStartBlock uint64
15-
1613
var committerCmd = &cobra.Command{
1714
Use: "committer",
1815
Short: "run committer",
1916
Long: "published data from s3 to kafka. if block is not found in s3, it will panic",
2017
Run: RunCommitter,
2118
}
2219

23-
func init() {
24-
committerCmd.Flags().Uint64Var(&committerStartBlock, "start-block", 0, "start committing from this block number (overrides ClickHouse max block when > 0)")
25-
}
26-
2720
func RunCommitter(cmd *cobra.Command, args []string) {
2821
fmt.Println("running committer")
2922

30-
if committerStartBlock > 0 {
31-
config.Cfg.CommitterStartBlock = committerStartBlock
32-
log.Info().Uint64("start_block", committerStartBlock).Msg("Committer start block override enabled")
33-
}
34-
3523
// Start Prometheus metrics server
3624
log.Info().Msg("Starting Metrics Server on port 2112")
3725
go func() {

0 commit comments

Comments
 (0)