public void restartSource(String groupId, String streamId) {
        List<StreamSource> sources = sourceService.listSource(groupId, streamId);
        sources.stream()
                .filter(source -> source.getTaskMapId() != null)
                .forEach(source -> sourceService.restart(source.getId(), GLOBAL_OPERATOR));
        groupMapper.updateStatus(groupId, GroupStatus.CONFIG_SUCCESSFUL.getCode(), GLOBAL_OPERATOR);
        streamMapper.updateStatusByIdentifier(groupId, streamId, StreamStatus.CONFIG_SUCCESSFUL.getCode(),
                GLOBAL_OPERATOR);
    }
mock {@link InlongGroupProcessService#restartProcessAsync}, it will restart stream source
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java