diff --git a/docs/changelog/139685.yaml b/docs/changelog/139685.yaml new file mode 100644 index 0000000000000..97f8f32020555 --- /dev/null +++ b/docs/changelog/139685.yaml @@ -0,0 +1,5 @@ +pr: 139685 +summary: Reduce priority of clear-cache tasks +area: Machine Learning +type: bug +issues: [] diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/registry/ClearInferenceEndpointCacheAction.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/registry/ClearInferenceEndpointCacheAction.java index 75fda546e84d8..c966ab4dc3c89 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/registry/ClearInferenceEndpointCacheAction.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/registry/ClearInferenceEndpointCacheAction.java @@ -90,7 +90,7 @@ public ClearInferenceEndpointCacheAction( ); this.projectResolver = projectResolver; this.inferenceEndpointRegistry = inferenceEndpointRegistry; - this.taskQueue = clusterService.createTaskQueue(TASK_QUEUE_NAME, Priority.IMMEDIATE, new CacheMetadataUpdateTaskExecutor()); + this.taskQueue = clusterService.createTaskQueue(TASK_QUEUE_NAME, Priority.NORMAL, new CacheMetadataUpdateTaskExecutor()); clusterService.addListener( event -> event.state() .metadata() diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/persistence/TrainedModelCacheMetadataService.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/persistence/TrainedModelCacheMetadataService.java index 65420c6c15073..d77460f2af01c 100644 --- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/persistence/TrainedModelCacheMetadataService.java +++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/persistence/TrainedModelCacheMetadataService.java @@ -40,7 +40,7 @@ public class TrainedModelCacheMetadataService implements ClusterStateListener { public TrainedModelCacheMetadataService(ClusterService clusterService, Client client) { this.client = new OriginSettingClient(client, ML_ORIGIN); CacheMetadataUpdateTaskExecutor metadataUpdateTaskExecutor = new CacheMetadataUpdateTaskExecutor(); - this.metadataUpdateTaskQueue = clusterService.createTaskQueue(TASK_QUEUE_NAME, Priority.IMMEDIATE, metadataUpdateTaskExecutor); + this.metadataUpdateTaskQueue = clusterService.createTaskQueue(TASK_QUEUE_NAME, Priority.NORMAL, metadataUpdateTaskExecutor); clusterService.addListener(this); }