private void startScheduler() {
      needScheduler = false;
      schedulerInFlight = true;
    }
Returns the next operation by this taskWorker
samza-core/src/main/java/org/apache/samza/container/RunLoop.java