fix ipni task column name (#248)

filecoin-project · Oct 4, 2024 · b9d1c93 · b9d1c93
1 parent 201069c
commit b9d1c93
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/tasks/indexing/task_indexing.go b/tasks/indexing/task_indexing.go
@@ -54,7 +54,7 @@ func NewIndexingTask(db *harmonydb.DB, sc *ffi.SealCalls, indexStore *indexstore
 type itask struct {
 	UUID        string                  `db:"uuid"`
 	SpID        int64                   `db:"sp_id"`
-	Sector      abi.SectorNumber        `db:"sector_number"`
+	Sector      abi.SectorNumber        `db:"sector"`
 	Proof       abi.RegisteredSealProof `db:"reg_seal_proof"`
 	PieceCid    string                  `db:"piece_cid"`
 	Size        abi.PaddedPieceSize     `db:"piece_size"`
@@ -73,7 +73,7 @@ func (i *IndexingTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (do
 	err = i.db.Select(ctx, &tasks, `SELECT 
 											uuid, 
 											sp_id, 
-											sector_number, 
+											sector,
 											piece_cid, 
 											piece_size, 
 											sector_offset,

diff --git a/tasks/indexing/task_ipni.go b/tasks/indexing/task_ipni.go
@@ -300,7 +300,7 @@ func (I *IPNITask) schedule(ctx context.Context, taskFunc harmonytask.AddTaskFun
 			err := I.db.Select(ctx, &pendings, `SELECT
     										uuid, 
 											sp_id, 
-											sector_number, 
+											sector,
 											piece_cid, 
 											piece_size, 
 											sector_offset,