fix cond

Signed-off-by: Tim Vaillancourt <[email protected]>
vitessio · Dec 17, 2024 · 8a9c944 · 8a9c944
1 parent 3198115
commit 8a9c944
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/go/vt/vtorc/logic/keyspace_shard_discovery.go b/go/vt/vtorc/logic/keyspace_shard_discovery.go
@@ -109,18 +109,16 @@ func RefreshAllKeyspacesAndShards(ctx context.Context) error {
 
 	if err = eg.Wait(); err == nil {
 		// delete stale records from the previous success or older
-		if staleTime := lastAllKeyspaceShardsRefreshTime; !staleTime.IsZero() {
-			if staleTime.Unix() == time.Now().Unix() {
-				return nil
-			}
+		now := time.Now()
+		if staleTime := lastAllKeyspaceShardsRefreshTime; !staleTime.IsZero() && now.Unix() > staleTime.Unix() {
 			if err := inst.DeleteStaleShards(staleTime); err != nil {
 				return err
 			}
 			if err := inst.DeleteStaleKeyspaces(staleTime); err != nil {
 				return err
 			}
 		}
-		lastAllKeyspaceShardsRefreshTime = time.Now()
+		lastAllKeyspaceShardsRefreshTime = now
 	}
 
 	return nil