From 86116b4bf794f397205b9a8389bab79ab1e317e6 Mon Sep 17 00:00:00 2001 From: erwinvaneyk Date: Fri, 16 Mar 2018 19:55:18 +0100 Subject: [PATCH] Bump controller tick speed to 100 ms --- pkg/controller/controller.go | 2 +- pkg/controller/invocation/controller.go | 2 +- pkg/controller/workflow/controller.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go index ee5d1a03..7ecbfe60 100644 --- 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 index 9d1befa7..32238c11 100644 --- 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 index 7a135f6c..d53bcf5b 100644 --- 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)