diff --git a/provider/lpseal/poller_commit_msg.go b/provider/lpseal/poller_commit_msg.go
index d17ccd906ee..19784e71911 100644
--- a/provider/lpseal/poller_commit_msg.go
+++ b/provider/lpseal/poller_commit_msg.go
@@ -97,7 +97,7 @@ func (s *SealPoller) pollRetryCommitMsgSend(ctx context.Context, task pollTask,
 	// make the pipeline entry seem like precommit send didn't happen, next poll loop will retry
 
 	_, err := s.db.Exec(ctx, `UPDATE sectors_sdr_pipeline SET
-                                commit_msg_cid = NULL, task_id_commit_msg = NULL
+                                commit_msg_cid = NULL, task_id_commit_msg = NULL, after_commit_msg = FALSE
                             	WHERE commit_msg_cid = $1 AND sp_id = $2 AND sector_number = $3 AND after_commit_msg_success = FALSE`,
 		*execResult.CommitMsgCID, task.SpID, task.SectorNumber)
 	if err != nil {
diff --git a/provider/lpseal/poller_precommit_msg.go b/provider/lpseal/poller_precommit_msg.go
index 5f6958b53fa..22deadc0eb7 100644
--- a/provider/lpseal/poller_precommit_msg.go
+++ b/provider/lpseal/poller_precommit_msg.go
@@ -108,7 +108,7 @@ func (s *SealPoller) pollRetryPrecommitMsgSend(ctx context.Context, task pollTas
 	// make the pipeline entry seem like precommit send didn't happen, next poll loop will retry
 
 	_, err := s.db.Exec(ctx, `UPDATE sectors_sdr_pipeline SET
-                                precommit_msg_cid = NULL, task_id_precommit_msg = NULL
+                                precommit_msg_cid = NULL, task_id_precommit_msg = NULL, after_precommit_msg = FALSE
                             	WHERE precommit_msg_cid = $1 AND sp_id = $2 AND sector_number = $3 AND after_precommit_msg_success = FALSE`,
 		*execResult.PrecommitMsgCID, task.SpID, task.SectorNumber)
 	if err != nil {