Skip to content

Commit ca7feb3

Browse files
Metrics: Update branch count
1 parent c487447 commit ca7feb3

1 file changed

Lines changed: 11 additions & 3 deletions

File tree

internal/workflow/workflow.go

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,16 +5,19 @@ import (
55
"encoding/json"
66
"errors"
77
"fmt"
8-
"github.com/serverledge-faas/serverledge/internal/client"
9-
"golang.org/x/exp/slices"
108
"io"
119
"net/http"
1210
"sort"
1311
"time"
1412

13+
"log"
14+
15+
"github.com/serverledge-faas/serverledge/internal/client"
16+
"github.com/serverledge-faas/serverledge/internal/metrics"
17+
"golang.org/x/exp/slices"
18+
1519
"github.com/serverledge-faas/serverledge/internal/cache"
1620
"github.com/serverledge-faas/serverledge/utils"
17-
"log"
1821

1922
"github.com/serverledge-faas/serverledge/internal/asl"
2023
"github.com/serverledge-faas/serverledge/internal/function"
@@ -228,6 +231,11 @@ func (workflow *Workflow) ExecuteTask(r *Request, taskToExecute TaskId, input *T
228231
if workflow.IsTaskEligibleForExecution(nextTaskId, progress) {
229232
progress.ReadyToExecute = append(progress.ReadyToExecute, nextTaskId)
230233
}
234+
235+
// Update metrics, if enabled
236+
if metrics.Enabled {
237+
metrics.AddBranchCount(string(task.GetId()), string(nextTaskId))
238+
}
231239
case *EndTask:
232240
progress.Complete(task.GetId())
233241
outputData = input

0 commit comments

Comments
 (0)