diff --git a/internal/runner/runner.go b/internal/runner/runner.go index 1703eb3..b7a3d53 100644 --- a/internal/runner/runner.go +++ b/internal/runner/runner.go @@ -65,10 +65,8 @@ func FromContext(ctx context.Context) (Runner, bool) { // monitorExecutionsRunnerID passes the id of the runner executing the execution into the monitoring Point p. func monitorExecutionsRunnerID(env dto.EnvironmentID, runnerID string) storage.WriteCallback[*dto.ExecutionRequest] { - return func(p *write.Point, e *dto.ExecutionRequest, eventType storage.EventType) { - if eventType == storage.Creation && e != nil { - p.AddTag(monitoring.InfluxKeyRunnerID, runnerID) - p.AddTag(monitoring.InfluxKeyEnvironmentID, env.ToString()) - } + return func(p *write.Point, _ *dto.ExecutionRequest, _ storage.EventType) { + p.AddTag(monitoring.InfluxKeyEnvironmentID, env.ToString()) + p.AddTag(monitoring.InfluxKeyRunnerID, runnerID) } }