code: static <T extends IncrementalTask> IncrementalTaskState<T> create(
        String taskId, String jobId, long createTime, T initialTask) {
      return new IncrementalTaskState<>(taskId, jobId, createTime, new LockInfo(null, null),
          checkNotNull(initialTask), new Status(StatusCode.RUNNING));
    }
docs: Returns a new running IncrementalTaskState.