private async Task StartExportAsync()

in code/KustoCopyConsole/Runner/ExportingRunner.cs [270:298]

• 28 lines of code
• 1 McCabe index (conditional complexity)

        private async Task StartExportAsync(BlockRowItem item, CancellationToken ct)
        {
            var activity = RowItemGateway.InMemoryCache.ActivityMap[item.ActivityName].RowItem;
            var iteration = RowItemGateway.InMemoryCache
                .ActivityMap[item.ActivityName]
                .IterationMap[item.IterationId]
                .RowItem;
            var dbClient = DbClientFactory.GetDbCommandClient(
                activity.SourceTable.ClusterUri,
                activity.SourceTable.DatabaseName);
            var writableUris = await StagingBlobUriProvider.GetWritableFolderUrisAsync(
                item.GetBlockKey(),
                ct);
            var query = Parameterization.Activities[item.ActivityName].KqlQuery;
            var operationId = await dbClient.ExportBlockAsync(
                new KustoPriority(item.GetBlockKey()),
                writableUris,
                activity.SourceTable.TableName,
                query,
                iteration.CursorStart,
                iteration.CursorEnd,
                item.IngestionTimeStart,
                item.IngestionTimeEnd,
                ct);
            var newBlockItem = item.ChangeState(BlockState.Exporting);

            newBlockItem.ExportOperationId = operationId;
            RowItemGateway.Append(newBlockItem);
        }