added more often checks about new encodings

Kirari04 · Jan 22, 2024 · 2fcd564 · 2fcd564
1 parent 7cf5feb
commit 2fcd564
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/services/Encoder.go b/services/Encoder.go
@@ -50,7 +50,7 @@ func Encoder() {
 	limitChan = make(chan bool, config.ENV.MaxRunningEncodes)
 	for {
 		go loadEncodingTasks()
-		time.Sleep(time.Second * 60)
+		time.Sleep(time.Second * 10)
 	}
 }
 
@@ -95,6 +95,7 @@ func loadEncodingTasks() {
 			Failed:   false,
 		}, "Encoding", "Ready", "Failed").
 		Order("id ASC").
+		Limit(10).
 		Find(&encodingSubs)
 
 	if len(encodingSubs) > 0 {
@@ -122,6 +123,7 @@ func loadEncodingTasks() {
 			Failed:   false,
 		}, "Encoding", "Ready", "Failed").
 		Order("id ASC").
+		Limit(10).
 		Find(&encodingAudios)
 
 	if len(encodingAudios) > 0 {
@@ -149,6 +151,7 @@ func loadEncodingTasks() {
 			Failed:   false,
 		}, "Encoding", "Ready", "Failed").
 		Order("id ASC").
+		Limit(10).
 		Find(&encodingQualitys)
 
 	if len(encodingQualitys) > 0 {