From 2f45646a92f3f3d903809e7d994b094443c6ddf1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Thu, 4 Jan 2024 16:57:31 +0100 Subject: [PATCH] lpseal: write precommit message to message_waits --- lib/harmony/harmonydb/sql/20231217-sdr-pipeline.sql | 2 -- provider/lpseal/task_submit_precommit.go | 5 +++++ 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/lib/harmony/harmonydb/sql/20231217-sdr-pipeline.sql b/lib/harmony/harmonydb/sql/20231217-sdr-pipeline.sql index c0540148f..c30a17e7c 100644 --- a/lib/harmony/harmonydb/sql/20231217-sdr-pipeline.sql +++ b/lib/harmony/harmonydb/sql/20231217-sdr-pipeline.sql @@ -41,8 +41,6 @@ create table sectors_sdr_pipeline ( -- precommit message wait seed_epoch bigint, precommit_msg_tsk bytea, - - task_id_precommit_msg_wait bigint, after_precommit_msg_success bool not null default false, -- seed diff --git a/provider/lpseal/task_submit_precommit.go b/provider/lpseal/task_submit_precommit.go index cfd8a31fb..198d53e43 100644 --- a/provider/lpseal/task_submit_precommit.go +++ b/provider/lpseal/task_submit_precommit.go @@ -120,6 +120,11 @@ func (s *SubmitPrecommitTask) Do(taskID harmonytask.TaskID, stillOwned func() bo return false, xerrors.Errorf("updating precommit_msg_cid: %w", err) } + _, err = s.db.Exec(ctx, `INSERT INTO message_waits (signed_message_cid) VALUES ($1)`, mcid) + if err != nil { + return false, xerrors.Errorf("inserting into message_waits: %w", err) + } + return true, nil }