Fix remaining CS8602 warnings in Cosmos and SqlServer extensions

Co-authored-by: philnach <[email protected]>

Author: Copilot

Extensions/Cosmos/Cosmos.DataTransfer.CosmosExtension/CosmosDataSinkExtension.cs

@@ -139,10 +139,10 @@ public async Task WriteAsync(IAsyncEnumerable<IDataItem> dataItems, IConfigurati
             var settings = config.Get<CosmosSinkSettings>();
             settings.Validate();
 
-            var client = CosmosExtensionServices.CreateClient(settings, DisplayName, dataSource.DisplayName);
+            var client = CosmosExtensionServices.CreateClient(settings!, DisplayName, dataSource.DisplayName);
 
             Container container;
-            if (settings.UseRbacAuth)
+            if (settings!.UseRbacAuth)
             {
                 var cosmosContainer = client.GetContainer(settings.Database, settings.Container);
                 container = settings.InitClientEncryption

Extensions/Cosmos/Cosmos.DataTransfer.CosmosExtension/CosmosDataSourceExtension.cs

@@ -18,11 +18,11 @@ public async IAsyncEnumerable<IDataItem> ReadAsync(IConfiguration config, ILogge
             var settings = config.Get<CosmosSourceSettings>();
             settings.Validate();
 
-            var client = CosmosExtensionServices.CreateClient(settings, DisplayName);
+            var client = CosmosExtensionServices.CreateClient(settings!, DisplayName);
 
             Container container;
 
-            if(settings.InitClientEncryption)
+            if(settings!.InitClientEncryption)
             {
                 container = await client.GetContainer(settings.Database, settings.Container).InitializeEncryptionAsync(cancellationToken);
             }

Extensions/SqlServer/Cosmos.DataTransfer.SqlServerExtension/SqlServerDataSourceExtension.cs

@@ -48,7 +48,7 @@ public async IAsyncEnumerable<IDataItem> ReadAsync(
                 settings.Validate();
 
                 await connection.OpenAsync(cancellationToken);
-                var command = connection.CreateCommand();
+                var command = connection.CreateCommand()!;
                 command.CommandText = queryText;
                 command.Parameters.AddRange(parameters);