diff --git a/extern/storage-sealing/fsm.go b/extern/storage-sealing/fsm.go index 0a4dedbf2..c2662bea8 100644 --- a/extern/storage-sealing/fsm.go +++ b/extern/storage-sealing/fsm.go @@ -113,7 +113,7 @@ var fsmPlanners = map[SectorState]func(events []statemachine.Event, state *Secto on(SectorCommitFailed{}, CommitFailed), ), SubmitCommitAggregate: planOne( - on(SectorCommitAggregateSent{}, CommitWait), + on(SectorCommitAggregateSent{}, CommitAggregateWait), on(SectorCommitFailed{}, CommitFailed), on(SectorRetrySubmitCommit{}, SubmitCommit), ), diff --git a/extern/storage-sealing/fsm_test.go b/extern/storage-sealing/fsm_test.go index 1d2df2784..c36369053 100644 --- a/extern/storage-sealing/fsm_test.go +++ b/extern/storage-sealing/fsm_test.go @@ -135,7 +135,7 @@ func TestHappyPathFinalizeEarly(t *testing.T) { require.Equal(m.t, m.state.State, SubmitCommitAggregate) m.planSingle(SectorCommitAggregateSent{}) - require.Equal(m.t, m.state.State, CommitWait) + require.Equal(m.t, m.state.State, CommitAggregateWait) m.planSingle(SectorProving{}) require.Equal(m.t, m.state.State, FinalizeSector) diff --git a/extern/storage-sealing/states_sealing.go b/extern/storage-sealing/states_sealing.go index 0df000eda..f21db3368 100644 --- a/extern/storage-sealing/states_sealing.go +++ b/extern/storage-sealing/states_sealing.go @@ -710,11 +710,8 @@ func (m *Sealing) handleSubmitCommitAggregate(ctx statemachine.Context, sector S Proof: sector.Proof, // todo: this correct?? Spt: sector.SectorType, }) - if err != nil { - return ctx.Send(SectorRetrySubmitCommit{}) - } - if res.Error != "" { + if err != nil || res.Error != "" { tok, _, err := m.Api.ChainHead(ctx.Context()) if err != nil { log.Errorf("handleSubmitCommit: api error, not proceeding: %+v", err)