diff --git a/tasks/message/watch.go b/tasks/message/watch.go
index 3297deea7..f250d53ca 100644
--- a/tasks/message/watch.go
+++ b/tasks/message/watch.go
@@ -148,7 +148,7 @@ func (mw *MessageWatcher) update() {
 			continue // definitely not on chain yet
 		}
 
-		look, err := mw.api.StateSearchMsg(ctx, lbtsk, cid.MustParse(msg.Cid), api.LookbackNoLimit, false)
+		look, err := mw.api.StateSearchMsg(ctx, lbtsk, cid.MustParse(msg.Cid), api.LookbackNoLimit, true)
 		if err != nil {
 			log.Errorf("failed to search for message: %+v", err)
 			return