in code/KustoCopyConsole/Runner/AwaitExportedRunner.cs [100:120]
private void DetectLostOperationIds(
IImmutableDictionary<string, BlockRowItem> operationIdMap,
IImmutableList<ExportOperationStatus> status)
{
var statusOperationIdBag = status.Select(s => s.OperationId).ToHashSet();
foreach (var id in operationIdMap.Keys)
{
if (!statusOperationIdBag.Contains(id))
{
var block = operationIdMap[id];
TraceWarning($"Warning! Operation ID lost: '{id}' for " +
$"block {block.BlockId} (Iteration={block.IterationId}, " +
$"Activity='{block.ActivityName}') ; block marked for reprocessing");
block.ExportOperationId = string.Empty;
block.ChangeState(BlockState.Planned);
RowItemGateway.Append(block);
}
}
}