fix(indexer): wait for persist routines to complete in Close (#396)

fixes #374

Author: frrist

chain/indexer.go

@@ -446,6 +446,8 @@ func (t *TipSetIndexer) Close() error {
 			log.Errorw("error received while closing actor task processor", "error", err, "task", name)
 		}
 	}
+	// ensure there are no persist go routines left running
+	t.persistSlot <- struct{}{}
 	return nil
 }
 

vector/runner.go

@@ -8,7 +8,6 @@ import (
 	"errors"
 	"fmt"
 	"os"
-	"time"
 
 	"github.com/google/go-cmp/cmp/cmpopts"
 
@@ -118,8 +117,6 @@ func (r *Runner) Run(ctx context.Context) error {
 	if err := chain.NewWalker(tsIndexer, r.opener, r.schema.Params.From, r.schema.Params.To).Run(ctx); err != nil && !errors.Is(err, context.Canceled) {
 		return err
 	}
-	// TODO remove when https://github.com/filecoin-project/sentinel-visor/issues/374 is fixed
-	time.Sleep(3 * time.Second)
 	return nil
 }