Test for named timer

Author: cschleiden

workflow/executor/executor_test.go

@@ -598,6 +598,9 @@ func Test_Executor(t *testing.T) {
 					// Schedule but not wait for timer
 					wf.ScheduleTimer(ctx, time.Second*2)
 
+					// Schedule but not wait for named timer
+					wf.ScheduleTimer(ctx, time.Second*2, wf.WithTimerName("delay"))
+
 					return nil
 				}
 
@@ -606,7 +609,7 @@ func Test_Executor(t *testing.T) {
 
 				task := startWorkflowTask("instanceID", workflow)
 
-				require.PanicsWithValue(t, "workflow completed, but there are still pending futures: [1-subworkflow:1 2-timer:2s]", func() {
+				require.PanicsWithValue(t, "workflow completed, but there are still pending futures: [1-subworkflow:1 2-timer:2s 3-timer-delay:2s]", func() {
 					e.ExecuteTask(context.Background(), task)
 				})
 			},

workflow/timer.go

@@ -61,7 +61,15 @@ func ScheduleTimer(ctx Context, delay time.Duration, opts ...timerOption) Future
 
 	timerCmd := command.NewScheduleTimerCommand(scheduleEventID, at, timerConfig.Name, traceContext)
 	wfState.AddCommand(timerCmd)
-	wfState.TrackFuture(scheduleEventID, workflowstate.AsDecodingSettable(contextvalue.Converter(ctx), fmt.Sprintf("timer:%s:%v", timerConfig.Name, delay), f))
+
+	timerSuffix := ""
+	if timerConfig.Name != "" {
+		timerSuffix = "-" + timerConfig.Name
+	}
+
+	wfState.TrackFuture(
+		scheduleEventID,
+		workflowstate.AsDecodingSettable(contextvalue.Converter(ctx), fmt.Sprintf("timer%s:%v", timerSuffix, delay), f))
 
 	cancelReceiver := &sync.Receiver[struct{}]{
 		Receive: func(v struct{}, ok bool) {