IC
Size: a a a
IC
NT
NT
E
DP
IC
E
DP
NT
A
AH
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());
}
IC
AH
AH
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.Select(p => p.ToString()).ToArray());
})
.ForEach(x =>
{
var (cluster, start, logs) = x;
afterTask(cluster, start, logs).GetAwaiter().GetResult();
});