process items

processasync.cs

List<Task> tasks = new List<Task>();

for (int i = 0; i < parallelTaskCount; i++)
{
  tasks.Add(Task.Run(async () =>
  {
    try
    {
      await ProcessScopeAsync(provider.CreateScope());
    }
    catch (Exception ex) when (Job.Config.Execution.HandleExceptions)
    {
      logger.LogError(ex, $"Unhandled exception in {nameof(ExecutionBase<TConfig, TItem>.ProcessScopeAsync)}");
    }
  }));
}

await Task.WhenAll(tasks);