diff --git a/chain/events/filter/index.go b/chain/events/filter/index.go
index dee4e5bf7e1..9085eb81c34 100644
--- a/chain/events/filter/index.go
+++ b/chain/events/filter/index.go
@@ -522,7 +522,7 @@ func (ei *EventIndex) Close() error {
 }
 
 func (ei *EventIndex) CollectEvents(ctx context.Context, te *TipSetEvents, revert bool, resolver func(ctx context.Context, emitter abi.ActorID, ts *types.TipSet) (address.Address, bool)) error {
-	tx, err := ei.db.Begin()
+	tx, err := ei.db.BeginTx(ctx, nil)
 	if err != nil {
 		return xerrors.Errorf("begin transaction: %w", err)
 	}