15m segment queue

livekit · Sep 9, 2024 · beca5a4 · beca5a4
1 parent 79afb24
commit beca5a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/pipeline/sink/segments.go b/pkg/pipeline/sink/segments.go
@@ -35,7 +35,6 @@ import (
 )
 
 const (
-	maxPendingUploads         = 100
 	defaultLivePlaylistWindow = 5
 )
 
@@ -91,6 +90,7 @@ func newSegmentSink(u uploader.Uploader, p *config.PipelineConfig, o *config.Seg
 		outputType = types.OutputTypeTS
 	}
 
+	maxPendingUploads := 900 / o.SegmentDuration
 	s := &SegmentSink{
 		Uploader:              u,
 		SegmentConfig:         o,