From 15f5f4745d11773fd2b361d6fbeba66e8bb68a92 Mon Sep 17 00:00:00 2001
From: 0x5459 <0x5459@protonmail.com>
Date: Mon, 29 Apr 2024 18:21:40 +0800
Subject: [PATCH] fix(pipeline): should return if error occurred when get
 network version (#11902)

---
 storage/pipeline/states_replica_update.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/storage/pipeline/states_replica_update.go b/storage/pipeline/states_replica_update.go
index a0d92891c..85e3fabee 100644
--- 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)