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
 }