From 86cddb827a8e2f5b166f92e9767266330326dd2c Mon Sep 17 00:00:00 2001 From: erwinvaneyk Date: Fri, 25 Aug 2017 00:02:16 -0700 Subject: [PATCH] Formatting --- cmd/workflow-engine/app/bootstrap.go | 4 ++-- pkg/controller/query/expr.go | 2 +- pkg/controller/query/scope.go | 8 ++++---- pkg/types/typedvalues/reserved.go | 2 +- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/cmd/workflow-engine/app/bootstrap.go b/cmd/workflow-engine/app/bootstrap.go index 85e5656a..47d1f1a6 100644 --- a/cmd/workflow-engine/app/bootstrap.go +++ b/cmd/workflow-engine/app/bootstrap.go @@ -13,18 +13,18 @@ import ( "github.com/fission/fission-workflow/pkg/apiserver" "github.com/fission/fission-workflow/pkg/cache" "github.com/fission/fission-workflow/pkg/controller" + "github.com/fission/fission-workflow/pkg/controller/query" inats "github.com/fission/fission-workflow/pkg/eventstore/nats" "github.com/fission/fission-workflow/pkg/fnenv/fission" ip "github.com/fission/fission-workflow/pkg/projector/project/invocation" wp "github.com/fission/fission-workflow/pkg/projector/project/workflow" "github.com/fission/fission-workflow/pkg/scheduler" + "github.com/fission/fission-workflow/pkg/types/typedvalues" "github.com/gorilla/handlers" "github.com/grpc-ecosystem/grpc-gateway/runtime" "github.com/nats-io/go-nats-streaming" log "github.com/sirupsen/logrus" "google.golang.org/grpc" - "github.com/fission/fission-workflow/pkg/controller/query" - "github.com/fission/fission-workflow/pkg/types/typedvalues" ) const ( diff --git a/pkg/controller/query/expr.go b/pkg/controller/query/expr.go index 73dcec71..70f98b6d 100644 --- a/pkg/controller/query/expr.go +++ b/pkg/controller/query/expr.go @@ -23,7 +23,7 @@ task(). dependency(id). guid - */ +*/ func NewJavascriptExpressionParser(parser typedvalues.Parser) *JavascriptExpressionParser { // TODO inject helper functions vm := otto.New() diff --git a/pkg/controller/query/scope.go b/pkg/controller/query/scope.go index fb5ba018..064d5342 100644 --- a/pkg/controller/query/scope.go +++ b/pkg/controller/query/scope.go @@ -46,10 +46,10 @@ func NewScope(wf *types.Workflow, invoc *types.WorkflowInvocation) *Scope { tasks[taskId] = &TaskScope{ ObjectMetadata: fn.Metadata, FunctionInvocationStatus: fn.Status, - Inputs: formatTypedValueMap(fn.Spec.Inputs), - Dependencies: wf.Spec.Tasks[taskId].Dependencies, - Name: wf.Spec.Tasks[taskId].Name, - Output: out, + Inputs: formatTypedValueMap(fn.Spec.Inputs), + Dependencies: wf.Spec.Tasks[taskId].Dependencies, + Name: wf.Spec.Tasks[taskId].Name, + Output: out, } } diff --git a/pkg/types/typedvalues/reserved.go b/pkg/types/typedvalues/reserved.go index 401f05d3..b638149c 100644 --- a/pkg/types/typedvalues/reserved.go +++ b/pkg/types/typedvalues/reserved.go @@ -16,7 +16,7 @@ const ( func Expr(expr string) *types.TypedValue { return &types.TypedValue{ - Type: FormatType(TYPE_EXPRESSION), + Type: FormatType(TYPE_EXPRESSION), Value: []byte(expr), } }