From 7fa3309b8e39eb0f901bacac2ba1ba52fc383ab0 Mon Sep 17 00:00:00 2001
From: 0x5459 <0x5459@protonmail.com>
Date: Fri, 19 Apr 2024 13:49:43 +0800
Subject: [PATCH] fix(pipeline): should return if error occurred when get
 network version

---
 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 a0d92891cd2..85e3fabee79 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)