Skip to content

Commit

Permalink
fix(pipeline): should return if error occurred when get network versi…
Browse files Browse the repository at this point in the history
…on (#11902)
  • Loading branch information
0x5459 authored Apr 29, 2024
1 parent 10877d2 commit 15f5f47
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions storage/pipeline/states_replica_update.go
Original file line number Diff line number Diff line change
Expand Up @@ -174,6 +174,7 @@ func (m *Sealing) handleSubmitReplicaUpdate(ctx statemachine.Context, sector Sec
nv, err := m.Api.StateNetworkVersion(ctx.Context(), ts.Key())
if err != nil {
log.Errorf("failed to get network version: %+v", err)
return ctx.Send(SectorSubmitReplicaUpdateFailed{})
}

pams, deals, err := m.processPieces(ctx.Context(), sector, nv >= network.Version22)
Expand Down

0 comments on commit 15f5f47

Please sign in to comment.