.

Azure · Jan 23, 2025 · cc4a853 · cc4a853
1 parent a0bf0bb
commit cc4a853
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 10 deletions.
diff --git a/code/KustoCopyConsole/Program.cs b/code/KustoCopyConsole/Program.cs
@@ -153,18 +153,18 @@ private static async Task RunOptionsAsync(CommandLineOptions options)
                 cancellationTokenSource.Cancel();
                 taskCompletionSource.Task.Wait();
             };
+            Trace.WriteLine("");
+            Trace.WriteLine("Parameterization:");
+            Trace.WriteLine("");
+            Trace.WriteLine(parameterization.ToYaml());
+            Trace.WriteLine("");
             try
             {
                 await using (var mainRunner = await MainRunner.CreateAsync(
                     parameterization,
                     options.LogFilePath,
                     cancellationTokenSource.Token))
                 {
-                    Trace.WriteLine("");
-                    Trace.WriteLine("Parameterization:");
-                    Trace.WriteLine("");
-                    Trace.WriteLine(parameterization.ToYaml());
-                    Trace.WriteLine("");
                     Trace.WriteLine("Processing...");
                     Trace.WriteLine("");
                     await mainRunner.RunAsync(cancellationTokenSource.Token);

diff --git a/code/KustoCopyConsole/Storage/AzureStorage/AzureBlobAppendStorage.cs b/code/KustoCopyConsole/Storage/AzureStorage/AzureBlobAppendStorage.cs
@@ -11,16 +11,15 @@ namespace KustoCopyConsole.Storage.AzureStorage
 {
     internal class AzureBlobAppendStorage : IAppendStorage
     {
-        private static readonly AsyncPolicy _writeBlockRetryPolicy = Policy.Handle<RequestFailedException>(
-            ex => ex.ErrorCode == "ConditionNotMet")
+        private static readonly AsyncPolicy _writeBlockRetryPolicy =
+            Policy.Handle<RequestFailedException>()
             .RetryAsync(3);
 
         private readonly DataLakeFileClient _fileClient;
         private readonly AppendBlobClient _blobClient;
         private readonly BlobLock _blobLock;
         private int _writeCount = 0;
 
-
         #region Constructors
         private AzureBlobAppendStorage(
             DataLakeFileClient fileClient,

diff --git a/code/KustoCopyConsole/Storage/AzureStorage/BlobLock.cs b/code/KustoCopyConsole/Storage/AzureStorage/BlobLock.cs
@@ -21,7 +21,7 @@ internal class BlobLock : IAsyncDisposable
         private BlobLock(BlobLeaseClient leaseClient, CancellationToken ct)
         {
             LeaseClient = leaseClient;
-            _backgroundTask = BackGroundRenewLockAsync(ct);
+            _backgroundTask = Task.Run(() => BackGroundRenewLockAsync(ct));
         }
 
         internal static async Task<BlobLock> CreateAsync(

diff --git a/code/KustoCopyConsole/Storage/RowItemGateway.cs b/code/KustoCopyConsole/Storage/RowItemGateway.cs
@@ -40,7 +40,7 @@ private RowItemGateway(
             CancellationToken ct)
         {
             _appendStorage = appendStorage;
-            _backgroundTask = BackgroundPersistanceAsync(ct);
+            _backgroundTask = Task.Run(() => BackgroundPersistanceAsync(ct));
             InMemoryCache = cache;
         }