From eff815dc9e72b40c31d8d83475c762f9dc1a4d27 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Tue, 27 Feb 2024 23:16:57 +0100 Subject: [PATCH] lpseal: Fix message retry --- provider/lpseal/poller_commit_msg.go | 2 +- provider/lpseal/poller_precommit_msg.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/provider/lpseal/poller_commit_msg.go b/provider/lpseal/poller_commit_msg.go index d17ccd906..19784e719 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 5f6958b53..22deadc0e 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 {