Skip to content

Commit 919ec18

Browse files
committed
Disable retries for sub-workflows by default
Closes #119
1 parent e8946b6 commit 919ec18

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

workflow/subworkflow.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,16 @@ type SubWorkflowOptions struct {
2222
RetryOptions RetryOptions
2323
}
2424

25-
var DefaultSubWorkflowOptions = SubWorkflowOptions{
26-
RetryOptions: DefaultRetryOptions,
27-
}
25+
var (
26+
DefaultSubWorkflowRetryOptions = RetryOptions{
27+
// Disable retries by default for sub-workflows
28+
MaxAttempts: 1,
29+
}
30+
31+
DefaultSubWorkflowOptions = SubWorkflowOptions{
32+
RetryOptions: DefaultSubWorkflowRetryOptions,
33+
}
34+
)
2835

2936
func CreateSubWorkflowInstance[TResult any](ctx sync.Context, options SubWorkflowOptions, workflow interface{}, args ...interface{}) Future[TResult] {
3037
return withRetries(ctx, options.RetryOptions, func(ctx sync.Context, attempt int) Future[TResult] {

0 commit comments

Comments
 (0)