var items = DateQuants()
                 .SelectMany(p => kustoClients, (l, r) => new WorkItem(r.Item1, r.Item2, l.Item1, l.Item2))
                 .AsParallel()
                 .WithDegreeOfParallelism(parallelism)
                 .Select(p =>
                 {
                     var logs = LogsBetween(p.Provider, p.Start, p.End).GetAwaiter().GetResult();
                     return (p.Cluster, p.Start, logs);
                 });

            foreach (var (cluster, start, logs) in items)
            {
                await afterTask(cluster, start, logs.Select(p => p.ToString()).ToArray());
            }

var logs = LogsBetween(p.Provider, p.Start, p.End).GetAwaiter().GetResult();