temporalio / temporalio/temporal
API for setting RPS limits for activity tasks dispatch
@Shivs11 is already working on this.
Since Nov 5, 2024.
- Dominant language
- Go
- Stars
- 23.2k
- Forks
- 1.9k
- Avg merge
- 2d 8h
- Merged PRs (30d)
- 228
Description
Is your feature request related to a problem? Please describe.
Currently, users are able to control the activity task dispatch RPS (rate per second) as a configuration option before instantiating a worker. After a worker has started and polls for tasks, this RPS value can only be changed by re-deploying the workers. This has proved to be a pain-point for some users
Describe the solution you'd like
I shall be working on implementing an API which shall allow customers to set this RPS limit. My implementation shall also prevent re-deploying of new/existing workers for changing the RPS value.
Describe alternatives you've considered
NA - This seems to be a good solution to solve the problem at hand.
Additional context
This is how customers set this limit, as of today:
w := worker.New(c, "hello-world", worker.Options{
TaskQueueActivitiesPerSecond: 100, // default value: 100K
})
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Assessment
This issue has not been assessed yet.