@Override
  public void reportProgress() {
    PROGRESS_REPORT_COUNT.incrementAndGet();
    LAST_PROGRESS_REPORT_TIME.set(System.currentTimeMillis());

    // To avoid deadlock
    CompletableFuture.runAsync(
        () -> PipeDataNodeAgent.task().markCompleted(pipeName, dataRegionId));
  }
The {@link PipeTerminateEvent} is an {@link EnrichedEvent} that controls the termination of pipe,
that is, when the historical {@link PipeTsFileInsertionEvent}s are all processed, this will be
reported next and mark the {@link PipeDataNodeTask} as completed. WARNING: This event shall never
be discarded.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/terminate/PipeTerminateEvent.java