docs: protected boolean isSendTuplesToInstance(List<Integer> taskIds) {
      for (Integer taskId : taskIds) {
        if (taskIdToInstanceExecutor.get(taskId).getStreamInQueue().remainingCapacity() <= 0) {
          return false;
        }
      }
  
      return true;
    }