Merge pull request #379 from lyuboxa/lk/exec-activity-via-name

Execute activity with name

Author: cschleiden

workflow/activity.go

@@ -40,16 +40,25 @@ func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt
 		return f
 	}
 
-	// Check return type
-	if err := a.ReturnTypeMatch[TResult](activity); err != nil {
-		f.Set(*new(TResult), err)
-		return f
-	}
+	var name string
+
+	// Check if activity is referred by name
+	if activityName, ok := activity.(string); ok {
+		name = activityName
+	} else {
+		// Check return type
+		if err := a.ReturnTypeMatch[TResult](activity); err != nil {
+			f.Set(*new(TResult), err)
+			return f
+		}
 
-	// Check arguments
-	if err := a.ParamsMatch(activity, args...); err != nil {
-		f.Set(*new(TResult), err)
-		return f
+		// Check arguments
+		if err := a.ParamsMatch(activity, args...); err != nil {
+			f.Set(*new(TResult), err)
+			return f
+		}
+
+		name = fn.Name(activity)
 	}
 
 	cv := contextvalue.Converter(ctx)
@@ -62,8 +71,6 @@ func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt
 	wfState := workflowstate.WorkflowState(ctx)
 	scheduleEventID := wfState.GetNextScheduleEventID()
 
-	name := fn.Name(activity)
-
 	// Capture context
 	propagators := propagators(ctx)
 	metadata := &Metadata{}

workflow/activity_test.go

@@ -62,3 +62,23 @@ func Test_executeActivity_ParamMismatch(t *testing.T) {
 	c.Execute()
 	require.True(t, c.Finished())
 }
+
+func Test_executeActivity_NameAsString(t *testing.T) {
+	ctx := sync.Background()
+	ctx = contextvalue.WithConverter(ctx, converter.DefaultConverter)
+	ctx = workflowstate.WithWorkflowState(
+		ctx,
+		workflowstate.NewWorkflowState(
+			core.NewWorkflowInstance("actName", ""), slog.Default(), noop.NewTracerProvider().Tracer("test"), clock.New()),
+	)
+
+	c := sync.NewCoroutine(ctx, func(ctx Context) error {
+		executeActivity[int](ctx, DefaultActivityOptions, 1, "actName", "foo", 1)
+		return nil
+	})
+
+	c.Execute()
+
+	require.NoError(t, c.Error())
+	require.True(t, c.Finished())
+}