Concurrency limits in temporal springboot

Community Support
,
1

I’m trying to set a concurrency limit of 10 on a task queue that I have (SelfServiceReqManagement), and was a bit confused on the options available for spring boot. Here is a snippet of code I currently have:

  @Bean
  public WorkerFactory workerFactory(WorkflowClient workflowClient,
                                     ServiceNowReqManagementImpl serviceNowReqManagement) {
    WorkerFactory workerFactory = WorkerFactory.newInstance(workflowClient);

    WorkerOptions workerOptions = WorkerOptions.newBuilder()
        .setMaxConcurrentActivityExecutionSize(10)
        .build();

    Worker worker = workerFactory.newWorker("ServiceNowReqManagement", workerOptions);
    worker.registerActivitiesImplementations(serviceNowReqManagement);

    return workerFactory;
  }

Is this code equivalent to setting these configurations in application.yml?

spring:
  temporal:
    workers:
      - task-queue: ServiceNowReqManagement
        capacity:
          max-concurrent-activity-executors: 1

Do they serve the same purpose or does max-concurrent-activity-executors do something different (and if so, what)?

2

.setMaxConcurrentActivityExecutionSize(10)
Is this code equivalent to setting these configurations in application.yml?

capacity:
max-concurrent-activity-executors: 10

yes, you are correct

I’m trying to set a concurrency limit of 10 on a task queue

note that MaxConcurrentActivityExecutionSize is a per-worker option, so you have 2 workers polling on this task.queue, each worker would be able to execute up to 10 concurrent activities at any point

3

If I want to limit the number of workers using the yaml approach, does max-concurrent-workflow-executors do this? If not, is there a way to limit the number of workers with spring configurations?

4

limit it by number of deployments of your springboot app, temporal spring boot starter creates a single worker per unique task queue you define as part of your ActivityImpl, WorkflowImpl annotations

1 Like