.

Author: vplauzon

code/KustoCopyConsole/KustoCopyConsole.csproj

@@ -28,7 +28,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="track-db" Version="0.5.2.30" />
+    <PackageReference Include="track-db" Version="0.5.3.31" />
     <PackageReference Include="Azure.Storage.Files.DataLake" Version="12.23.0" />
     <PackageReference Include="CommandLineParser" Version="2.9.1" />
     <PackageReference Include="Microsoft.Azure.Kusto.Data" Version="14.0.1" />

code/KustoCopyConsole/Runner/QueueIngestRunner.cs

@@ -107,7 +107,16 @@ private async Task QueueIngestBlockAsync(
             var ingestionBatches = operationTexts
                 .Select(op => new IngestionBatchRecord(block.BlockKey, op));
 
-            Database.IngestionBatches.AppendRecords(ingestionBatches);
+            using (var tc = Database.Database.CreateTransaction())
+            {
+                Database.Blocks.UpdateRecord(
+                    block,
+                    block with { State = BlockState.Queued },
+                    tc);
+                Database.IngestionBatches.AppendRecords(ingestionBatches);
+
+                tc.Complete();
+            }
 
             Trace.TraceInformation($"Block {block.BlockKey}:  {urlRecords.Length} urls queued");
         }