1515import org .elasticsearch .cluster .AckedClusterStateUpdateTask ;
1616import org .elasticsearch .cluster .ClusterState ;
1717import org .elasticsearch .cluster .ClusterStateAckListener ;
18- import org .elasticsearch .cluster .ClusterStateUpdateTask ;
1918import org .elasticsearch .cluster .ProjectState ;
2019import org .elasticsearch .cluster .SimpleBatchedAckListenerTaskExecutor ;
2120import org .elasticsearch .cluster .metadata .ProjectId ;
2625import org .elasticsearch .cluster .service .MasterServiceTaskQueue ;
2726import org .elasticsearch .common .Priority ;
2827import org .elasticsearch .core .Nullable ;
29- import org .elasticsearch .core .SuppressForbidden ;
3028import org .elasticsearch .core .Tuple ;
3129import org .elasticsearch .license .XPackLicenseState ;
3230import org .elasticsearch .reservedstate .ReservedClusterStateHandler ;
@@ -58,7 +56,6 @@ public class PutLifecycleMetadataService {
5856
5957 private static final Logger logger = LogManager .getLogger (PutLifecycleMetadataService .class );
6058
61- private final ClusterService clusterService ;
6259 private final NamedXContentRegistry xContentRegistry ;
6360 private final Client client ;
6461 private final XPackLicenseState licenseState ;
@@ -74,7 +71,6 @@ public PutLifecycleMetadataService(
7471 ThreadPool threadPool ,
7572 ProjectResolver projectResolver
7673 ) {
77- this .clusterService = clusterService ;
7874 this .xContentRegistry = xContentRegistry ;
7975 this .client = client ;
8076 this .licenseState = licenseState ;
@@ -83,11 +79,6 @@ public PutLifecycleMetadataService(
8379 this .taskQueue = clusterService .createTaskQueue ("ilm-put-lifecycle-queue" , Priority .NORMAL , new IlmLifecycleExecutor ());
8480 }
8581
86- @ SuppressForbidden (reason = "legacy usage of unbatched task" ) // TODO add support for batching here
87- private void submitUnbatchedTask (@ SuppressWarnings ("SameParameterValue" ) String source , ClusterStateUpdateTask task ) {
88- clusterService .submitUnbatchedStateUpdateTask (source , task );
89- }
90-
9182 public void addLifecycle (PutLifecycleRequest request , ClusterState state , ActionListener <AcknowledgedResponse > listener ) {
9283 // headers from the thread context stored by the AuthenticationService to be shared between the
9384 // REST layer and the Transport layer here must be accessed within this thread and not in the
0 commit comments