@Test
    public void testDelete() {
        final Pair<String, String> groupStream = saveSource(null);
        agent.pullTask();
        agent.pullTask(); // report last success status

        // suspend
        deleteSource(groupStream.getLeft(), groupStream.getRight());
        TaskResult taskResult = agent.pullTask();
        Assertions.assertEquals(1, taskResult.getDataConfigs().size());
        Assertions.assertEquals(1, taskResult.getDataConfigs().stream()
                .filter(dataConfig -> Integer.valueOf(dataConfig.getOp()) == ManagerOpEnum.DEL.getType())
                .collect(Collectors.toSet())
                .size());
    }
Test suspend group for source task.
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java