Fix archive view column mismatch, wait_stats thread-safety, percent_complete cast, status bar color

Lite/Controls/ServerTab.xaml.cs

@@ -2288,7 +2288,7 @@ private async void LiveSnapshot_Click(object sender, RoutedEventArgs e)
                     HostName = reader.IsDBNull(21) ? "" : reader.GetString(21),
                     ProgramName = reader.IsDBNull(22) ? "" : reader.GetString(22),
                     OpenTransactionCount = reader.IsDBNull(23) ? 0 : Convert.ToInt32(reader.GetValue(23)),
-                    PercentComplete = reader.IsDBNull(24) ? 0m : reader.GetDecimal(24),
+                    PercentComplete = reader.IsDBNull(24) ? 0m : Convert.ToDecimal(reader.GetValue(24)),
                     CollectionTime = snapshotTime
                 });
             }

Lite/Database/DuckDbInitializer.cs

@@ -101,20 +101,20 @@
     /// </summary>
     public async Task InitializeAsync()
     {
         _logger?.LogInformation("Initializing DuckDB database at {Path}", _databasePath);
 
         var directory = Path.GetDirectoryName(_databasePath);
         if (!string.IsNullOrEmpty(directory) && !Directory.Exists(directory))
         {
             Directory.CreateDirectory(directory);
             _logger?.LogInformation("Created database directory: {Directory}", directory);
         }
 
         var archivePath = Path.Combine(directory ?? ".", "archive");
         if (!Directory.Exists(archivePath))
         {
             Directory.CreateDirectory(archivePath);
             _logger?.LogInformation("Created archive directory: {ArchivePath}", archivePath);
         }
 
         /* Try to open the database. If the DuckDB storage version has changed,
@@ -143,7 +143,7 @@
 
             if (existingVersion < CurrentSchemaVersion)
             {
                 _logger?.LogInformation("Schema upgrade needed: v{Old} -> v{New}", existingVersion, CurrentSchemaVersion);
                 await RunMigrationsAsync(connection, existingVersion);
                 await SetSchemaVersionAsync(connection, CurrentSchemaVersion);
             }
@@ -158,7 +158,7 @@
                 await ExecuteNonQueryAsync(connection, indexStatement);
             }
 
             _logger?.LogInformation("Database initialization complete. Schema version: {Version}", CurrentSchemaVersion);
         }
 
         await CreateArchiveViewsAsync();
@@ -211,7 +211,7 @@
                 cmd.CommandText = $"EXPORT DATABASE '{exportDir.Replace("'", "''")}' (FORMAT PARQUET)";
                 await cmd.ExecuteNonQueryAsync();
                 exported = true;
                 _logger?.LogInformation("Exported old database to {ExportDir}", exportDir);
             }
         }
         catch (Exception ex)
@@ -225,7 +225,7 @@
         {
             /* DuckDB may have .wal files too */
             File.Move(_databasePath, backupPath);
             _logger?.LogInformation("Backed up old database to {BackupPath}", backupPath);
 
             var walPath = _databasePath + ".wal";
             if (File.Exists(walPath))
@@ -483,12 +483,12 @@
                 }
 
                 if (serverNames.Count > 0)
                     _logger?.LogInformation("Fixed server_id in {Table} for {Count} server(s)", table, serverNames.Count);
             }
             catch (Exception ex)
             {
                 /* Table might not exist yet — that's fine, it will be created with correct IDs */
                 _logger?.LogDebug(ex, "Skipped server_id fix for {Table} (may not exist yet)", table);
             }
         }
     }
@@ -522,7 +522,7 @@
                 if (hasParquetFiles)
                 {
                     var globPath = parquetGlob.Replace("\\", "/");
-                    viewSql = $"CREATE OR REPLACE VIEW v_{table} AS SELECT * FROM {table} UNION ALL SELECT * FROM read_parquet('{globPath}', union_by_name=true)";
+                    viewSql = $"CREATE OR REPLACE VIEW v_{table} AS SELECT * FROM {table} UNION ALL BY NAME SELECT * FROM read_parquet('{globPath}', union_by_name=true)";
                 }
                 else
                 {
@@ -550,7 +550,7 @@
             }
         }
 
         _logger?.LogDebug("Archive views created/refreshed for {Count} tables", ArchivableTables.Length);
     }
 
     /// <summary>

Lite/MainWindow.xaml.cs

@@ -354,7 +354,7 @@ private void UpdateCollectorHealth()
         else
         {
             CollectorHealthText.Text = $"Collectors: {health.TotalCollectors} OK";
-            CollectorHealthText.Foreground = (System.Windows.Media.Brush)FindResource("ForegroundMutedBrush");
+            CollectorHealthText.Foreground = (System.Windows.Media.Brush)FindResource("ForegroundBrush");
             CollectorHealthText.ToolTip = null;
         }
     }

Lite/Services/RemoteCollectorService.QuerySnapshots.cs

@@ -157,7 +157,7 @@ private async Task<int> CollectQuerySnapshotsAsync(ServerConnection server, Canc
                        .AppendValue(reader.IsDBNull(21) ? (string?)null : reader.GetString(21))                /* host_name */
                        .AppendValue(reader.IsDBNull(22) ? (string?)null : reader.GetString(22))                /* program_name */
                        .AppendValue(reader.IsDBNull(23) ? 0 : Convert.ToInt32(reader.GetValue(23)))            /* open_transaction_count */
-                       .AppendValue(reader.IsDBNull(24) ? 0m : reader.GetDecimal(24))                          /* percent_complete */
+                       .AppendValue(reader.IsDBNull(24) ? 0m : Convert.ToDecimal(reader.GetValue(24)))        /* percent_complete */
                        .EndRow();
 
                     rowsCollected++;

Lite/Services/RemoteCollectorService.WaitStats.cs

@@ -22,19 +22,15 @@ namespace PerformanceMonitorLite.Services;
 
 public partial class RemoteCollectorService
 {
-    private HashSet<string>? _ignoredWaitTypes;
+    private readonly Lazy<HashSet<string>> _ignoredWaitTypes;
 
     /// <summary>
-    /// Gets the set of wait types to ignore during collection.
+    /// Loads the set of wait types to ignore during collection.
+    /// Thread-safe via Lazy&lt;T&gt; (multiple server tasks call this in parallel).
     /// </summary>
-    private HashSet<string> GetIgnoredWaitTypes()
+    private HashSet<string> LoadIgnoredWaitTypes()
     {
-        if (_ignoredWaitTypes != null)
-        {
-            return _ignoredWaitTypes;
-        }
-
-        _ignoredWaitTypes = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
+        var waits = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
 
         var configPath = Path.Combine(App.ConfigDirectory, "ignored_wait_types.json");
         if (File.Exists(configPath))
@@ -51,7 +47,7 @@ private HashSet<string> GetIgnoredWaitTypes()
                         var waitType = wait.GetString();
                         if (!string.IsNullOrEmpty(waitType))
                         {
-                            _ignoredWaitTypes.Add(waitType);
+                            waits.Add(waitType);
                         }
                     }
                 }
@@ -62,7 +58,7 @@ private HashSet<string> GetIgnoredWaitTypes()
             }
         }
 
-        return _ignoredWaitTypes;
+        return waits;
     }
 
     /// <summary>
@@ -82,7 +78,7 @@ FROM sys.dm_os_wait_stats AS ws
 WHERE ws.wait_time_ms > 0
 OPTION(RECOMPILE);";
 
-        var ignoredWaits = GetIgnoredWaitTypes();
+        var ignoredWaits = _ignoredWaitTypes.Value;
         var serverId = GetServerId(server);
         var collectionTime = DateTime.UtcNow;
         var rowsCollected = 0;

Lite/Services/RemoteCollectorService.cs

@@ -112,6 +112,7 @@ public RemoteCollectorService(
         _scheduleManager = scheduleManager;
         _logger = logger;
         _deltaCalculator = new DeltaCalculator(logger);
+        _ignoredWaitTypes = new Lazy<HashSet<string>>(LoadIgnoredWaitTypes);
     }
 
     /// <summary>