diff --git a/internal/worker/worker.go b/internal/worker/worker.go index 2daf1bf3..ec1fd776 100644 --- a/internal/worker/worker.go +++ b/internal/worker/worker.go @@ -23,6 +23,7 @@ import ( "go.hollow.sh/toolbox/events/pkg/kv" "go.hollow.sh/toolbox/events/registry" "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/trace" cpv1types "github.com/metal-toolbox/conditionorc/pkg/api/v1/types" @@ -271,6 +272,8 @@ func (o *Worker) processSingleEvent(ctx context.Context, e events.Message) { return } + span.SetAttributes(attribute.KeyValue{Key: "conditionKind", Value: attribute.StringValue(condition.ID.String())}) + // check and see if the task is or has-been handled by another worker currentState := o.taskInProgress(condition.ID.String()) switch currentState {