diff --git a/pkg/pipeline/sink/segments.go b/pkg/pipeline/sink/segments.go
index 2ad0ec07..6cda02a5 100644
--- a/pkg/pipeline/sink/segments.go
+++ b/pkg/pipeline/sink/segments.go
@@ -199,6 +199,9 @@ func (s *SegmentSink) handlePlaylistUpdates(update SegmentUpdate) error {
 	s.throttle(func() {
 		s.playlistLock.Lock()
 		defer s.playlistLock.Unlock()
+		if s.done.IsBroken() {
+			return
+		}
 
 		if err := s.uploadPlaylist(); err != nil {
 			s.callbacks.OnError(err)