fix(pipeline): should return if error occurred when get network version (#11902)
This commit is contained in:
parent
10877d2e66
commit
15f5f4745d
@ -174,6 +174,7 @@ func (m *Sealing) handleSubmitReplicaUpdate(ctx statemachine.Context, sector Sec
|
|||||||
nv, err := m.Api.StateNetworkVersion(ctx.Context(), ts.Key())
|
nv, err := m.Api.StateNetworkVersion(ctx.Context(), ts.Key())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorf("failed to get network version: %+v", err)
|
log.Errorf("failed to get network version: %+v", err)
|
||||||
|
return ctx.Send(SectorSubmitReplicaUpdateFailed{})
|
||||||
}
|
}
|
||||||
|
|
||||||
pams, deals, err := m.processPieces(ctx.Context(), sector, nv >= network.Version22)
|
pams, deals, err := m.processPieces(ctx.Context(), sector, nv >= network.Version22)
|
||||||
|
Loading…
Reference in New Issue
Block a user