diff --git a/clientv3/watch.go b/clientv3/watch.go
index d50acbca3..87d222d1d 100644
--- a/clientv3/watch.go
+++ b/clientv3/watch.go
@@ -384,6 +384,7 @@ func (w *watcher) RequestProgress(ctx context.Context) (err error) {
 
 	w.mu.Lock()
 	if w.streams == nil {
+		w.mu.Unlock()
 		return fmt.Errorf("no stream found for context")
 	}
 	wgs := w.streams[ctxKey]