2121import org .elasticsearch .cluster .ClusterStateUpdateTask ;
2222import org .elasticsearch .cluster .ProjectState ;
2323import org .elasticsearch .cluster .SimpleBatchedAckListenerTaskExecutor ;
24- import org .elasticsearch .cluster .project .ProjectResolver ;
2524import org .elasticsearch .cluster .service .ClusterService ;
2625import org .elasticsearch .cluster .service .MasterServiceTaskQueue ;
2726import org .elasticsearch .common .Priority ;
@@ -146,7 +145,7 @@ public Tuple<ClusterState, ClusterStateAckListener> executeTask(
146145 ClusterState clusterState
147146 ) throws Exception {
148147
149- ProjectMetadata projectMetadata = clusterState .projectState ( updateSettingsTask . projectId ). metadata ( );
148+ ProjectMetadata projectMetadata = clusterState .metadata (). getProject ( updateSettingsTask . projectId );
150149 ProjectMetadata .Builder projectMetadataBuilder = ProjectMetadata .builder (projectMetadata );
151150 Map <String , DataStream > dataStreamMap = projectMetadata .dataStreams ();
152151 DataStream dataStream = dataStreamMap .get (updateSettingsTask .dataStreamName );
@@ -408,7 +407,7 @@ public static ClusterState setRolloverOnWrite(
408407 }
409408
410409 public void updateSettings (
411- ProjectResolver projectResolver ,
410+ ProjectId projectId ,
412411 TimeValue masterNodeTimeout ,
413412 TimeValue ackTimeout ,
414413 String dataStreamName ,
@@ -417,7 +416,7 @@ public void updateSettings(
417416 ) {
418417 updateSettingsTaskQueue .submitTask (
419418 "updating settings on data stream" ,
420- new UpdateSettingsTask (projectResolver . getProjectId () , dataStreamName , settingsOverrides , ackTimeout , listener ),
419+ new UpdateSettingsTask (projectId , dataStreamName , settingsOverrides , ackTimeout , listener ),
421420 masterNodeTimeout
422421 );
423422 }
0 commit comments