@@ -72,7 +72,7 @@ func (e *CacheEngine) setWorkerComponentStatus(componentValue *common.CacheRunti
7272
7373 return ready , err
7474}
75- func (e * CacheEngine ) setClientComponentStatus (componentValue * common.CacheRuntimeComponentValue , status * fluidapi.CacheRuntimeStatus ) (ready bool , err error ) {
75+ func (e * CacheEngine ) setClientComponentStatus (componentValue * common.CacheRuntimeComponentValue , status * fluidapi.CacheRuntimeStatus ) (fullyReady bool , err error ) {
7676 manager := component .NewComponentHelper (componentValue .WorkloadType , e .Scheme , e .Client )
7777
7878 clientStatus , err := manager .ConstructComponentStatus (context .TODO (), componentValue )
@@ -81,22 +81,22 @@ func (e *CacheEngine) setClientComponentStatus(componentValue *common.CacheRunti
8181 }
8282 if clientStatus .DesiredReplicas > 0 && clientStatus .ReadyReplicas >= clientStatus .DesiredReplicas {
8383 clientStatus .Phase = fluidapi .RuntimePhaseReady
84- ready = true
84+ fullyReady = true
8585 } else if clientStatus .ReadyReplicas > 0 {
8686 clientStatus .Phase = fluidapi .RuntimePhasePartialReady
8787 } else {
8888 clientStatus .Phase = fluidapi .RuntimePhaseNotReady
8989 }
9090 status .Client = clientStatus
9191
92- return ready , nil
92+ return fullyReady , nil
9393}
9494func (e * CacheEngine ) CheckAndUpdateRuntimeStatus (value * common.CacheRuntimeValue ) (bool , error ) {
9595 runtimeReady := false
9696
9797 err := retry .RetryOnConflict (retry .DefaultBackoff , func () error {
9898 // Reset readiness on each retry to avoid stale state after conflicts.
99- masterReady , workerReady , clientFullyReady := true , true , true
99+ masterReady , workerReady , clientFullyReady := true , true , false
100100 runtimeReady = false
101101
102102 runtime , err := e .getRuntime ()
0 commit comments