max concurrent activitiy

bcc-code · Sep 14, 2023 · f87d657 · f87d657
1 parent 7e6db8e
commit f87d657
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/cmd/worker/main.go b/cmd/worker/main.go
@@ -80,7 +80,11 @@ func main() {
 		EnableSessionWorker:                true,
 		Identity:                           identity,
 		LocalActivityWorkerOnly:            false,
-		MaxConcurrentActivityExecutionSize: 100, // Doesn't make sense to have more than one activity running at a time
+		MaxConcurrentActivityExecutionSize: 5, // Doesn't make sense to have more than one activity running at a time
+	}
+
+	if utils.GetQueue() == utils.GetTranscodeQueue() {
+		workerOptions.MaxConcurrentActivityExecutionSize = 1
 	}
 
 	w := worker.New(c, utils.GetQueue(), workerOptions)
@@ -123,6 +127,7 @@ func main() {
 			w.RegisterWorkflow(wf)
 		}
 	case common.QueueTranscode:
+
 		for _, a := range transcodeActivities {
 			w.RegisterActivity(a)
 		}