From 520aae362ecdac0b60c9aca19b83cac1061813de Mon Sep 17 00:00:00 2001
From: Grail Finder <wohilas@gmail.com>
Date: Fri, 17 Feb 2023 10:43:05 +0600
Subject: Feat: opus doesnt have 22khz; comment out

---
 ffmpeg.go | 2 +-
 main.go   | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/ffmpeg.go b/ffmpeg.go
index 1157707..e36c05b 100644
--- a/ffmpeg.go
+++ b/ffmpeg.go
@@ -13,7 +13,7 @@ func cutoutClipAndTranscode(ut *Utterance) error {
 			"to": ut.RightTime,
 		},
 	).Output(ut.OutPath, ffmpeg.KwArgs{
-		"ar":       "22050",
+		// "ar":       "22050",
 		"metadata": fmt.Sprintf(`source="%s"`, ut.FD.VttPath),
 	}).OverWriteOutput().ErrorToStdOut().Run()
 	return err
diff --git a/main.go b/main.go
index de3fa58..81d4a6a 100644
--- a/main.go
+++ b/main.go
@@ -12,7 +12,7 @@ import (
 
 const (
 	subExt          = ".vtt"
-	outdir          = "data/utterances"
+	outdir          = "/mnt/nvme/data"
 	ffCmdOut        = "data/ff_commands"
 	timeSep         = "-->"
 	metadataPath    = "data/metadata.json"
@@ -180,13 +180,15 @@ func main() {
 
 	fmt.Println("filled queue, starting workers")
 
-	workers := 10
+	workers := 100
 	for i := 0; i < workers; i++ {
 		go worker(queue, i, done)
 	}
 
 	for {
 		if len(queue) == 0 {
+			// give time for workers to finish
+			time.Sleep(3 * time.Second)
 			done <- true
 			close(done)
 			close(queue)
-- 
cgit v1.2.3