Merge pull request #129 from github/feature/follower_fix

skip cluster-scoped follower commands

Author: sdseaton

KustoSchemaTools/Changes/DatabaseChanges.cs

@@ -217,6 +217,12 @@ private static List<IChange> GenerateScriptCompareChanges<T>(Database oldState,
 
         public static List<IChange> GenerateFollowerChanges(FollowerDatabase oldState, FollowerDatabase newState, ILogger log)
         {
+            if (!SupportsFollowerClusterCommands())
+            {
+                log.LogDebug("Skipping follower database changes because cluster-scoped follower commands cannot be executed in the current rollout context.");
+                return [];
+            }
+
             List<IChange> result =
             [
                 .. GenerateFollowerCachingChanges(oldState, newState, db => db.Tables, "Table", "table"),
@@ -341,6 +347,24 @@ private static List<IChange> GenerateFollowerCachingChanges(FollowerDatabase old
             return result;
         }
 
+        private static bool SupportsFollowerClusterCommands()
+        {
+            var disableFlag = Environment.GetEnvironmentVariable("DISABLE_FOLLOWER_COMMANDS");
+
+            if (disableFlag == null)
+            {
+                return true;
+            }
+
+            var isDisabled = bool.TryParse(disableFlag, out var parsed)
+                ? parsed
+                : string.Equals(disableFlag, "1", StringComparison.OrdinalIgnoreCase)
+                  || string.Equals(disableFlag, "yes", StringComparison.OrdinalIgnoreCase)
+                  || string.Equals(disableFlag, "true", StringComparison.OrdinalIgnoreCase);
+
+            return !isDisabled;
+        }
+
         private static void LogChangeResult(ILogger log, string entityKey, int scriptCount, bool alreadyExists)
         {
             var level = scriptCount > 0 ? LogLevel.Information : LogLevel.Debug;