code: @Private
    @Override
    public void completed(final int taskletId, final TOutput result) {
      try {
        completedTasklets(result, Collections.singletonList(taskletId));
      } catch (final InterruptedException e) {
        throw new RuntimeException(e);
      }
    }
docs: A Tasklet associated with the aggregation has completed.