anchor.diff:      log.info("$i tasks deleted");
     }
   
  +  Future<Map<String, int>> queryTasksReady() async {
  +    log.info("Query task ready");
  +    // Task -> ready count
  +    Map<String, int> readyCounts = {};
  +
  +    final int READY_STATE = _intFromLifecycle(LifecycleState.READY);
  +
  +    var query = _db.query(_TaskModel)..filter("lifecycleState =", READY_STATE);
  +
  +    await for (_TaskModel model in query.run()) {
  +      String parentJobName = model.parentJobName;
  +      readyCounts.putIfAbsent(parentJobName, () => 0);
  +      readyCounts[parentJobName]++;
  +    }
  +    return readyCounts;
  +  }
  +
     Future<Map<String, Map<int, int>>> queryTaskState() async {
       log.info("Query task state");
   
  
positive.code:     log.trace("Set state on Task for $_objectKey -> $state : OK");
    }
  
    // Number of times this task has failed to execute
    Future<int> get failureCounts async {
      log.trace("Get failureCounts on Task for $_objectKey");
  
      await _pullBackingStore();
      return backingstore?.failureCount;
    }
  
  
negative.code: 
  const int DATASTORE_TRANSACTION_SIZE = 250;
  const String _UNALLOCATED_OWNER = "";
  const Duration BACKING_STORE_STALE_POLICY = const Duration(seconds: 120);
  
  
  db.DatastoreDB _db = db.dbService;
  
  