summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--ffmpeg.go2
-rw-r--r--main.go6
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)