public async Task QueueBlobAsync()

in code/KustoCopyConsole/Kusto/IngestClient.cs [33:67]

32 lines of code
2 McCabe index (conditional complexity)


        public async Task<string> QueueBlobAsync(
            KustoPriority priority,
            Uri blobPath,
            string extentTag,
            DateTime? creationTime,
            CancellationToken ct)
        {
            var tagList = new[] { extentTag };
            var properties = new KustoQueuedIngestionProperties(_database, _table)
            {
                Format = DataSourceFormat.parquet,
                AdditionalTags = tagList,
                ReportLevel = IngestionReportLevel.FailuresAndSuccesses,
                ReportMethod = IngestionReportMethod.Table
            };

            if (creationTime != null)
            {
                properties.AdditionalProperties.Add(
                    "creationTime",
                    creationTime.Value.ToString("o"));
            }

            return await _queue.RequestRunAsync(
                priority,
                async () =>
                {
                    var ingestionResult = await _ingestProvider.IngestFromStorageAsync(
                        blobPath.ToString(),
                        properties);
                    var serializedResult = IngestionResultSerializer.Serialize(ingestionResult);

                    return serializedResult;
                });
        }