From fa819abbb56a0b6e4d9d88a6ed072c12dd18e493 Mon Sep 17 00:00:00 2001 From: Yusuke Kuoka Date: Mon, 22 Apr 2024 06:15:08 +0000 Subject: [PATCH] Add job started attrs --- cmd/ghalistener/worker/worker.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/cmd/ghalistener/worker/worker.go b/cmd/ghalistener/worker/worker.go index 0aad0829..93ba6281 100644 --- a/cmd/ghalistener/worker/worker.go +++ b/cmd/ghalistener/worker/worker.go @@ -12,6 +12,7 @@ import ( jsonpatch "github.com/evanphx/json-patch" "github.com/go-logr/logr" "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" kerrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes" @@ -100,6 +101,13 @@ func (w *Worker) HandleJobStarted(ctx context.Context, jobInfo *actions.JobStart ctx, span := otel.Tracer("arc").Start(ctx, "Worker.HandleJobStarted") defer span.End() + span.SetAttributes( + attribute.String("runner.name", jobInfo.RunnerName), + attribute.String("runner.repo.name", jobInfo.RepositoryName), + attribute.String("workflow.ref", jobInfo.JobWorkflowRef), + attribute.Int64("workflow.run.id", jobInfo.WorkflowRunId), + ) + w.logger.Info("Updating job info for the runner", "runnerName", jobInfo.RunnerName, "ownerName", jobInfo.OwnerName,