Use Activity type

cschleiden · cschleiden · commit a0f6b1567dec · 2023-09-21T16:02:35.000-07:00
diff --git a/workflow/activity.go b/workflow/activity.go
@@ -26,13 +26,13 @@ var DefaultActivityOptions = ActivityOptions{
 }
 
 // ExecuteActivity schedules the given activity to be executed
-func ExecuteActivity[TResult any](ctx Context, options ActivityOptions, activity interface{}, args ...interface{}) Future[TResult] {
+func ExecuteActivity[TResult any](ctx Context, options ActivityOptions, activity Activity, args ...interface{}) Future[TResult] {
 	return WithRetries(ctx, options.RetryOptions, func(ctx Context, attempt int) Future[TResult] {
 		return executeActivity[TResult](ctx, options, attempt, activity, args...)
 	})
 }
 
-func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt int, activity interface{}, args ...interface{}) Future[TResult] {
+func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt int, activity Activity, args ...interface{}) Future[TResult] {
 	f := sync.NewFuture[TResult]()
 
 	if ctx.Err() != nil {

Original file line number	Diff line number	Diff line change
`@@ -26,13 +26,13 @@ var DefaultActivityOptions = ActivityOptions{`
`26`	`26`	`}`
`27`	`27`
`28`	`28`	`// ExecuteActivity schedules the given activity to be executed`
`29`		`-func ExecuteActivity[TResult any](ctx Context, options ActivityOptions, activity interface{}, args ...interface{}) Future[TResult] {`
	`29`	`+func ExecuteActivity[TResult any](ctx Context, options ActivityOptions, activity Activity, args ...interface{}) Future[TResult] {`
`30`	`30`	`return WithRetries(ctx, options.RetryOptions, func(ctx Context, attempt int) Future[TResult] {`
`31`	`31`	`return executeActivity[TResult](ctx, options, attempt, activity, args...)`
`32`	`32`	`})`
`33`	`33`	`}`
`34`	`34`
`35`		`-func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt int, activity interface{}, args ...interface{}) Future[TResult] {`
	`35`	`+func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt int, activity Activity, args ...interface{}) Future[TResult] {`
`36`	`36`	`f := sync.NewFuture[TResult]()`
`37`	`37`
`38`	`38`	`if ctx.Err() != nil {`