@Override
    public TaskEvent event() {
        return TaskEvent.COMPLETE;
    }
Test class for listen restart source event.
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockRestartSourceListener.java