Merge pull request #128 from fission/bump-controller-speed

Bump controller tick speed to 100 ms
fission · Mar 17, 2018 · 98aacfd · 98aacfd
2 parents 20fbec8 + 86116b4
commit 98aacfd
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -12,7 +12,7 @@ import (
 )
 
 const (
-	TickInterval = time.Duration(1) * time.Second
+	TickInterval = time.Duration(100) * time.Millisecond
 )
 
 var (

diff --git a/pkg/controller/invocation/controller.go b/pkg/controller/invocation/controller.go
@@ -210,7 +210,7 @@ func (cr *Controller) Evaluate(invocationId string) {
 		defer evalState.Free()
 	default:
 		// TODO provide option to wait for a lock
-		wfiLog.Infof("Failed to obtain access to invocation %s", invocationId)
+		wfiLog.Debugf("Failed to obtain access to invocation %s", invocationId)
 		return
 	}
 	log.Debugf("evaluating invocation %s", invocationId)

diff --git a/pkg/controller/workflow/controller.go b/pkg/controller/workflow/controller.go
@@ -141,7 +141,7 @@ func (c *Controller) Evaluate(workflowId string) {
 		defer evalState.Free()
 	default:
 		// TODO provide option to wait for a lock
-		wfLog.Infof("Failed to obtain access to workflow %s", workflowId)
+		wfLog.Debugf("Failed to obtain access to workflow %s", workflowId)
 		return
 	}
 	wfLog.Debugf("evaluating workflow %s", workflowId)
-Original file line number
+Diff line change
@@ Expand Up / @@ -12,7 +12,7 @@ import ( @@
     )
     const (
-    	TickInterval = time.Duration(1) * time.Second
+    	TickInterval = time.Duration(100) * time.Millisecond
     )
     var (
@@ Expand Down @@