fix(pipeline): should return if error occurred when get network version

filecoin-project · Apr 19, 2024 · 7fa3309 · 7fa3309
1 parent 031802e
commit 7fa3309
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/storage/pipeline/states_replica_update.go b/storage/pipeline/states_replica_update.go
@@ -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)