Skip to content

Commit 745a7d3

Browse files
committed
fix more CI and update according to reviews
1 parent 3bb4ccf commit 745a7d3

File tree

4 files changed

+5
-8
lines changed

4 files changed

+5
-8
lines changed

coordinator/internal/controller/api/get_task.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,10 +47,6 @@ func NewGetTaskController(cfg *config.Config, chainCfg *params.ChainConfig, db *
4747
return ptc
4848
}
4949

50-
func (ptc *GetTaskController) ProverTasks() map[message.ProofType]provertask.ProverTask {
51-
return ptc.proverTasks
52-
}
53-
5450
func (ptc *GetTaskController) incGetTaskAccessCounter(ctx *gin.Context) error {
5551
publicKey, publicKeyExist := ctx.Get(coordinatorType.PublicKey)
5652
if !publicKeyExist {

coordinator/internal/logic/provertask/bundle_prover_task.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,8 @@ func (bp *BundleProverTask) Assign(ctx *gin.Context, getTaskParameter *coordinat
173173
log.Error("Generate universal prover task failure", "task_id", bundleTask.Hash, "type", "bundle")
174174
return nil, ErrCoordinatorInternalFailure
175175
}
176+
// bundle proof require snark
177+
taskMsg.UseSnark = true
176178
proverTask.Metadata = metadata
177179
}
178180

coordinator/internal/logic/provertask/prover_task.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,6 @@ func (b *BaseProverTask) checkParameter(ctx *gin.Context) (*proverTaskContext, e
187187
}
188188

189189
func (b *BaseProverTask) applyUniversal(schema *coordinatorType.GetTaskSchema) (*coordinatorType.GetTaskSchema, []byte, error) {
190-
191190
ok, uTaskData, metadata, _ := libzkp.GenerateUniversalTask(schema.TaskType, schema.TaskData, schema.HardForkName)
192191
if !ok {
193192
return nil, nil, fmt.Errorf("can not generate universal task, see coordinator log for the reason")

database/migrate/migrate_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,20 +59,20 @@ func testResetDB(t *testing.T) {
5959
cur, err := Current(pgDB)
6060
assert.NoError(t, err)
6161
// total number of tables.
62-
assert.Equal(t, int64(27), cur)
62+
assert.Equal(t, int64(28), cur)
6363
}
6464

6565
func testMigrate(t *testing.T) {
6666
assert.NoError(t, Migrate(pgDB))
6767
cur, err := Current(pgDB)
6868
assert.NoError(t, err)
69-
assert.Equal(t, int64(27), cur)
69+
assert.Equal(t, int64(28), cur)
7070
}
7171

7272
func testRollback(t *testing.T) {
7373
version, err := Current(pgDB)
7474
assert.NoError(t, err)
75-
assert.Equal(t, int64(27), version)
75+
assert.Equal(t, int64(28), version)
7676

7777
assert.NoError(t, Rollback(pgDB, nil))
7878

0 commit comments

Comments
 (0)