activeTaskIdsFor method

List<String> activeTaskIdsFor(
  1. String workerId
)

Ids of tasks currently TaskState.started (or just TaskState.pending after TaskInfo.receivedAt) on workerId.

Implementation

List<String> activeTaskIdsFor(String workerId) {
  final ids = <String>[];
  for (final t in _tasks.values) {
    if (t.workerId != workerId) continue;
    final inFlight = t.state == TaskState.started ||
        (t.state == TaskState.pending && t.receivedAt != null);
    if (inFlight) ids.add(t.id);
  }
  return ids;
}