fix: Batching Hotfixes (#351)

filecoin-project · Jan 6, 2025 · a5972b0 · a5972b0
1 parent d0e5f5e
commit a5972b0
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/harmony/harmonydb/sql/20241210-sdr-batching.sql b/harmony/harmonydb/sql/20241210-sdr-batching.sql
@@ -1,6 +1,9 @@
 ALTER TABLE sectors_sdr_pipeline ADD COLUMN precommit_ready_at TIMESTAMPTZ;
 ALTER TABLE sectors_sdr_pipeline ADD COLUMN commit_ready_at TIMESTAMPTZ;
 
+UPDATE sectors_sdr_pipeline SET precommit_ready_at = CURRENT_TIMESTAMP AT TIME ZONE 'UTC' WHERE after_tree_r = TRUE;
+UPDATE sectors_sdr_pipeline SET commit_ready_at = CURRENT_TIMESTAMP AT TIME ZONE 'UTC' WHERE after_porep = TRUE;
+
 -- Function to precommit_ready_at value. Used by the trigger
 CREATE OR REPLACE FUNCTION set_precommit_ready_at()
 RETURNS TRIGGER AS $$

diff --git a/tasks/seal/poller.go b/tasks/seal/poller.go
@@ -5,6 +5,7 @@ import (
 	"time"
 
 	logging "github.com/ipfs/go-log/v2"
+	"github.com/samber/lo"
 	"golang.org/x/xerrors"
 
 	"github.com/filecoin-project/go-address"
@@ -238,11 +239,12 @@ func (s *SealPoller) poll(ctx context.Context) error {
 		return err
 	}
 
+	tasks = lo.Filter(tasks, func(t pollTask, _ int) bool {
+		return !t.Failed
+	})
+
 	for _, task := range tasks {
 		task := task
-		if task.Failed {
-			continue
-		}
 
 		ts, err := s.api.ChainHead(ctx)
 		if err != nil {

diff --git a/tasks/snap/task_submit.go b/tasks/snap/task_submit.go
@@ -502,7 +502,7 @@ func (s *SubmitTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.Tas
 
 func (s *SubmitTask) TypeDetails() harmonytask.TaskTypeDetails {
 	return harmonytask.TaskTypeDetails{
-		Name: "BatchUpdateSubmit",
+		Name: "UpdateBatch",
 		Cost: resources.Resources{
 			Cpu: 1,
 			Ram: 64 << 20,