Bumped compose version to .97

functions/onprem/orborus/orborus.go

@@ -122,11 +122,17 @@ func getThisContainerId() {
 // https://docs.docker.com/engine/api/sdk/examples/
 func deployWorker(image string, identifier string, env []string) {
 	// Binds is the actual "-v" volume.
+	// Max 20% CPU every second
 	hostConfig := &container.HostConfig{
 		LogConfig: container.LogConfig{
 			Type:   "json-file",
 			Config: map[string]string{},
 		},
+		Resources: container.Resources{
+			CPUShares: 256,
+			CPUQuota:  25000,
+			CPUPeriod: 100000,
+		},
 		Binds: []string{
 			"/var/run/docker.sock:/var/run/docker.sock:rw",
 		},

functions/onprem/worker/build.sh

@@ -1,5 +1,5 @@
 NAME=shuffle-worker
-VERSION=0.8.92
+VERSION=0.8.97
 
 echo "Running docker build with $NAME:$VERSION"
 #CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o worker.bin .

functions/onprem/worker/worker.go

@@ -199,14 +199,17 @@ func shutdown(workflowExecution shuffle.WorkflowExecution, nodeId string, reason
 func deployApp(cli *dockerclient.Client, image string, identifier string, env []string, workflowExecution shuffle.WorkflowExecution) error {
 	// form basic hostConfig
 	ctx := context.Background()
+
+	// Max 10% CPU every second
 	hostConfig := &container.HostConfig{
 		LogConfig: container.LogConfig{
 			Type:   "json-file",
 			Config: map[string]string{},
 		},
 		Resources: container.Resources{
-			CPUShares: 256,
-			CPUPeriod: 10000,
+			CPUShares: 128,
+			CPUQuota:  10000,
+			CPUPeriod: 100000,
 		},
 	}