-
Notifications
You must be signed in to change notification settings - Fork 27
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support activity retry policies #83
Conversation
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you add one or two integration tests that use this feature? I'd like to see what the programming model looks like when users write code that uses this feature.
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just a couple small test validation requests.
…task-go into support-retry-policies
Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good! Thanks for making these changes!
Note that I've updated the title of this PR to clarify that it only covers activity retry policies. Another PR will be needed to cover orchestration retry policies (which cover sub-orchestration scenarios). |
required of dapr/go-sdk#541
adds the
ActivityRetryPolicy
struct and updates CallActivity to execute a different code path if retries are needed.I tried to mimic the behavior of https://github.com/Azure/durabletask/blob/main/src/DurableTask.Core/RetryInterceptor.cs#L52
but in the case of golang I had to make it a recursive algorithm