images queue

livekit · Sep 9, 2024 · a925ad6 · a925ad6
1 parent beca5a4
commit a925ad6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/pipeline/sink/image.go b/pkg/pipeline/sink/image.go
@@ -54,6 +54,7 @@ type imageUpdate struct {
 }
 
 func newImageSink(u uploader.Uploader, p *config.PipelineConfig, o *config.ImageConfig, callbacks *gstreamer.Callbacks) (*ImageSink, error) {
+	maxPendingUploads := 900 / o.CaptureInterval
 	return &ImageSink{
 		Uploader:    u,
 		ImageConfig: o,