core: fix for transcoders waiting forever on a O restart if they had …

…a previous transcoding session (#2705)
livepeer · Jan 6, 2023 · af9de74 · af9de74
1 parent a3949f3
commit af9de74
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/ot_rpc.go b/server/ot_rpc.go
@@ -129,11 +129,11 @@ func runTranscoder(n *core.LivepeerNode, orchAddr string, capacity int, caps []c
 			wg.Wait()
 			return err
 		}
-		wg.Add(1)
 		if notify.SegData != nil && notify.SegData.AuthToken != nil && len(notify.SegData.AuthToken.SessionId) > 0 && len(notify.Url) == 0 {
 			// session teardown signal
 			n.Transcoder.EndTranscodingSession(notify.SegData.AuthToken.SessionId)
 		} else {
+			wg.Add(1)
 			go func() {
 				runTranscode(n, orchAddr, httpc, notify)
 				wg.Done()