for (var target in targets) {
  final task = tasks.singleWhere((task) => task.taskName == target.name);
  var policy = target.schedulerPolicy;

  // ... omitted for brevity ...

  final priority = await policy.triggerPriority(
    taskName: task.name!,
    commitSha: commit.sha,
    recentTasks: await firestoreService.queryRecentTasksByName(
      name: task.name!,
    ),
  );
  if (priority != null) {
    // Mark task as in progress to ensure it isn't scheduled over
    task.setStatus(ds.Task.statusInProgress);
    toBeScheduled.add(
      PendingTask(target: target, task: task, priority: priority),
    );
  }
}