retryactivity

README

Steps to run this sample:

1. You need a Temporal service running. See details in README.md
2. Run the following command to start the worker

go run retryactivity/worker/main.go

1. Run the following command to start the example

go run retryactivity/starter/main.go

Documentation

Index

• func BatchProcessingActivity(ctx context.Context, firstTaskID, batchSize int, processDelay time.Duration) error
• func RetryWorkflow(ctx workflow.Context) error

Functions

func BatchProcessingActivity

func BatchProcessingActivity(ctx context.Context, firstTaskID, batchSize int, processDelay time.Duration) error

BatchProcessingActivity process batchSize of jobs starting from firstTaskID. This activity will heartbeat to report progress, and it could fail sometimes. Use retry policy to retry when it failed, and resume from reported progress.

func RetryWorkflow

func RetryWorkflow(ctx workflow.Context) error

RetryWorkflow workflow definition