add event name to workflowtaskprocess as well

Author: yaananth

internal/metrickeys/metrickeys.go

@@ -7,7 +7,6 @@ const (
 	WorkflowInstanceCreated  = Prefix + "workflow.created"
 	WorkflowInstanceFinished = Prefix + "workflow.finished"
 
-	WorkflowTaskScheduled = Prefix + "workflow.task.scheduled"
 	WorkflowTaskProcessed = Prefix + "workflow.task.processed"
 	WorkflowTaskDelay     = Prefix + "workflow.task.time_in_queue"
 
@@ -32,5 +31,5 @@ const (
 	ContinuedAsNew = "continued_as_new"
 
 	ActivityName = "activity"
-	EventName   = "event"
+	EventName    = "event"
 )

internal/worker/workflow.go

@@ -143,12 +143,16 @@ func (ww *WorkflowWorker) handle(ctx context.Context, t *task.Workflow) {
 		scheduledAt = firstEvent.Timestamp // Use the timestamp of the first event as the schedule time
 	}
 
+	eventName := fmt.Sprint(firstEvent.Type)
+
 	timeInQueue := time.Since(scheduledAt)
 	ww.backend.Metrics().Distribution(metrickeys.WorkflowTaskDelay, metrics.Tags{
-		metrickeys.EventName: fmt.Sprint(t.NewEvents[0].Type),
+		metrickeys.EventName: eventName,
 	}, float64(timeInQueue/time.Millisecond))
 
-	timer := metrics.Timer(ww.backend.Metrics(), metrickeys.WorkflowTaskProcessed, metrics.Tags{})
+	timer := metrics.Timer(ww.backend.Metrics(), metrickeys.WorkflowTaskProcessed, metrics.Tags{
+		metrickeys.EventName: eventName,
+	})
 
 	result, err := ww.handleTask(ctx, t)
 	if err != nil {