From 0f285a6a5d703fb3a72a6e4a5c7f05a4061493fc Mon Sep 17 00:00:00 2001 From: Hannah Howard Date: Thu, 8 Jul 2021 14:11:28 -0700 Subject: [PATCH] fix(tasks): return error if update channel shuts down (#279) --- tasks/storage_deal.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tasks/storage_deal.go b/tasks/storage_deal.go index f84038b..c47fa11 100644 --- a/tasks/storage_deal.go +++ b/tasks/storage_deal.go @@ -348,7 +348,7 @@ func (de *storageDealExecutor) executeAndMonitorDeal(ctx context.Context, update return fmt.Errorf("deal stage %q %s", stage, msg) case info, ok := <-updates: if !ok { - return nil + return fmt.Errorf("Client error: Update channel closed before deal is active") } if !proposalCid.Equals(info.ProposalCid) {