Skip to content

Commit c21eb60

Browse files
committed
Use IO executor for workload controller. (#9839)
1 parent 9725ee2 commit c21eb60

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

airbyte-workload-api-server/src/main/kotlin/io/airbyte/workload/api/WorkloadApi.kt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@ import io.airbyte.workload.metrics.StatsDRegistryConfigurer.Companion.WORKLOAD_I
2020
import io.micronaut.http.HttpStatus
2121
import io.micronaut.http.annotation.Controller
2222
import io.micronaut.http.annotation.Status
23+
import io.micronaut.scheduling.TaskExecutors
24+
import io.micronaut.scheduling.annotation.ExecuteOn
2325
import io.micronaut.security.annotation.Secured
2426
import io.micronaut.security.rules.SecurityRule
2527
import io.swagger.v3.oas.annotations.Operation
@@ -38,6 +40,7 @@ import javax.ws.rs.Produces
3840

3941
@Controller("/api/v1/workload")
4042
@Secured(SecurityRule.IS_AUTHENTICATED)
43+
@ExecuteOn(TaskExecutors.IO)
4144
open class WorkloadApi(
4245
private val workloadHandler: WorkloadHandler,
4346
private val workloadService: WorkloadService,

airbyte-workload-api-server/src/main/resources/application.yml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,9 @@ micronaut:
22
application:
33
name: airbyte-workload-api-server
44
executors:
5-
health:
5+
io:
66
type: fixed
7-
n-threads: ${HEALTH_TASK_EXECUTOR_THREADS:10}
7+
n-threads: ${IO_TASK_EXECUTOR_THREADS:10} # Match the data source max pool size below
88
metrics:
99
enabled: true
1010
export:

0 commit comments

Comments
 (0)