temporalio / temporalio/temporal

API for setting RPS limits for activity tasks dispatch

Open
#6,758 2 comments 0 reactions 1 assignee View on GitHub

@Shivs11 is already working on this.

Since Nov 5, 2024.

enhancement
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

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.