add log, combine booleans

linkedin · Dec 10, 2024 · f84707f · f84707f
1 parent e3f65d2
commit f84707f
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/.../venice-controller/src/main/java/com/linkedin/venice/pushmonitor/AbstractPushMonitor.java b/.../venice-controller/src/main/java/com/linkedin/venice/pushmonitor/AbstractPushMonitor.java
@@ -1135,11 +1135,19 @@ private void updateStoreVersionStatus(String storeName, int versionNumber, Versi
            *  after targetSwapRegionWaitTime passes)
            */
           Set<String> targetRegions = RegionUtils.parseRegionsFilterList(version.getTargetSwapRegion());
-          boolean isValidTargetRegion = targetRegions.contains(regionName);
-          boolean isTargetRegionPushWithDeferredSwap = version.isVersionSwapDeferred() && isValidTargetRegion;
+          boolean isTargetRegionPushWithDeferredSwap =
+              version.isVersionSwapDeferred() && targetRegions.contains(regionName);
           boolean isNormalPush = !version.isVersionSwapDeferred();
           boolean isDeferredSwap = version.isVersionSwapDeferred() && targetRegions.isEmpty();
           if (isTargetRegionPushWithDeferredSwap || isNormalPush) {
+            LOGGER.debug(
+                "Swapping to version {} for store {} in region {}. isTargetRegionPushWithDeferredSwap is {} and"
+                    + "isNormalPush is {}",
+                versionNumber,
+                store.getName(),
+                regionName,
+                isTargetRegionPushWithDeferredSwap,
+                isNormalPush);
             int previousVersion = store.getCurrentVersion();
             store.setCurrentVersion(versionNumber);
             realTimeTopicSwitcher.transmitVersionSwapMessage(store, previousVersion, versionNumber);