FEATURE: Added max concurrency executions to orborus
This commit is contained in:
+1
-1
@@ -45,7 +45,7 @@ services:
|
|||||||
- database
|
- database
|
||||||
orborus:
|
orborus:
|
||||||
#build: ./functions/onprem/orborus
|
#build: ./functions/onprem/orborus
|
||||||
image: ghcr.io/frikky/shuffle-orborus:0.8.32
|
image: ghcr.io/frikky/shuffle-orborus:0.8.40
|
||||||
container_name: shuffle-orborus
|
container_name: shuffle-orborus
|
||||||
hostname: shuffle-orborus
|
hostname: shuffle-orborus
|
||||||
networks:
|
networks:
|
||||||
|
|||||||
@@ -324,6 +324,7 @@ func main() {
|
|||||||
tmpInt, err := strconv.Atoi(concurrencyEnv)
|
tmpInt, err := strconv.Atoi(concurrencyEnv)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
maxConcurrency = tmpInt
|
maxConcurrency = tmpInt
|
||||||
|
log.Printf("[INFO] Max workflow execution concurrency set to %d", maxConcurrency)
|
||||||
} else {
|
} else {
|
||||||
log.Printf("[WARNING] Env SHUFFLE_ORBORUS_EXECUTION_CONCURRENCY must be a number, not %s. Defaulted to %d", workerTimeoutEnv, maxConcurrency)
|
log.Printf("[WARNING] Env SHUFFLE_ORBORUS_EXECUTION_CONCURRENCY must be a number, not %s. Defaulted to %d", workerTimeoutEnv, maxConcurrency)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user