fixup

Author: nonsense

extern/boostd-data/cmd/run.go

@@ -34,6 +34,7 @@ var runCmd = &cli.Command{
 		leveldbCmd,
 		yugabyteCmd,
 		yugabyteMigrateCmd,
+		yugabyteAddIndexCmd,
 	},
 }
 
@@ -274,15 +275,17 @@ var yugabyteAddIndexCmd = &cli.Command{
 			Usage:    "postgres connect string eg 'postgresql://postgres:postgres@localhost'",
 			Required: true,
 		},
-		&cli.StringFlag{
-			Name:  "miner-address",
-			Usage: "default miner address eg f1234",
-		},
 		&cli.StringFlag{
 			Name:     "filename",
 			Usage:    "",
 			Required: true,
 		},
+		&cli.IntFlag{
+			Name:     "CQLTimeout",
+			Usage:    "client timeout value in seconds for CQL queries",
+			Required: false,
+			Value:    yugabyte.CqlTimeout,
+		},
 	},
 	Action: func(cctx *cli.Context) error {
 		ctx := cliutil.ReqContext(cctx)
@@ -291,11 +294,16 @@ var yugabyteAddIndexCmd = &cli.Command{
 		settings := yugabyte.DBSettings{
 			Hosts:         cctx.StringSlice("hosts"),
 			ConnectString: cctx.String("connect-string"),
+			CQLTimeout:    cctx.Int("CQLTimeout"),
 		}
 
 		migrator := yugabyte.NewMigrator(settings, migrations.DisabledMinerAddr)
 
 		bdsvc := svc.NewYugabyte(settings, migrator)
+		err := bdsvc.Impl.Start(ctx)
+		if err != nil {
+			return err
+		}
 
 		piececidStr := cctx.String("filename")
 
@@ -336,7 +344,7 @@ var yugabyteAddIndexCmd = &cli.Command{
 			return fmt.Errorf("generating index for piece %s: %w", piececid, err)
 		}
 
-		log.Warnw("read index successfully", "took", time.Since(now))
+		log.Warnw("read index successfully", "piececid", piececid, "recs", len(recs), "took", time.Since(now))
 
 		now = time.Now()
 
@@ -345,6 +353,7 @@ var yugabyteAddIndexCmd = &cli.Command{
 			if resp.Err != "" {
 				return fmt.Errorf("failed to add index to yugabytedb: %s", resp.Err)
 			}
+			log.Warnw("adding index to yugabytedb", "progress", resp.Progress)
 		}
 		log.Warnw("added index to yugabytedb successfully", "took", time.Since(now))