fix: GetUnassignedBatchCount

scroll-tech · Dec 30, 2024 · 8ce5121 · 8ce5121
1 parent 71acdb3
commit 8ce5121
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/coordinator/internal/orm/batch.go b/coordinator/internal/orm/batch.go
@@ -100,6 +100,7 @@ func (o *Batch) GetUnassignedBatchCount(ctx context.Context, maxActiveAttempts,
 	db = db.Where("proving_status = ?", int(types.ProvingTaskUnassigned))
 	db = db.Where("total_attempts < ?", maxTotalAttempts)
 	db = db.Where("active_attempts < ?", maxActiveAttempts)
+	db = db.Where("chunk_proofs_status = ?", int(types.ChunkProofsStatusReady))
 	db = db.Where("batch.deleted_at IS NULL")
 	if err := db.Count(&count).Error; err != nil {
 		return 0, fmt.Errorf("Batch.GetUnassignedBatchCount error: %w", err)