diff --git a/venona/VERSION b/venona/VERSION index 50ffc5aa..2165f8f9 100644 --- a/venona/VERSION +++ b/venona/VERSION @@ -1 +1 @@ -2.0.3 +2.0.4 diff --git a/venona/pkg/agent/agent.go b/venona/pkg/agent/agent.go index 066bffca..8de42db4 100644 --- a/venona/pkg/agent/agent.go +++ b/venona/pkg/agent/agent.go @@ -262,7 +262,6 @@ func (a *Agent) reportTaskStatus(ctx context.Context, taskDef task.Task, err err } func (a *Agent) getTasks(ctx context.Context) (task.Tasks, []*workflow.Workflow) { - metrics.IncGetTasksRequests() tasks := a.pullTasks(ctx) return a.splitTasks(tasks) } diff --git a/venona/pkg/codefresh/codefresh.go b/venona/pkg/codefresh/codefresh.go index bc87c6de..f744a052 100644 --- a/venona/pkg/codefresh/codefresh.go +++ b/venona/pkg/codefresh/codefresh.go @@ -23,6 +23,7 @@ import ( "net/url" "path" + "github.com/codefresh-io/go/venona/pkg/metrics" "github.com/codefresh-io/go/venona/pkg/task" ) @@ -80,6 +81,7 @@ func New(opts Options) Codefresh { // Tasks get from Codefresh all latest tasks func (c cf) Tasks(ctx context.Context) (task.Tasks, error) { + metrics.IncGetTasksRequests() query := map[string]string{ "waitForStatusReport": "true", } diff --git a/venonactl/VERSION b/venonactl/VERSION index 50ffc5aa..2165f8f9 100644 --- a/venonactl/VERSION +++ b/venonactl/VERSION @@ -1 +1 @@ -2.0.3 +2.0.4