private boolean completelyDelete(String groupId) throws Exception {
        // Trigger the removal of the DAG file for the Cleaner DAG
        DAGRunConf dagRunConf = DAGRunConf.builder()
                .inlongGroupId(DAGUtil.buildDAGIdByGroupId(groupId)).build();
        AirflowResponse<DAGRun> response = serverClient.sendRequest(
                new DAGRunsTrigger(airflowConfig.getDagCleanerId(), ImmutableMap.of("conf", dagRunConf)));
        LOGGER.info("Response to DAG file clearing: {}", response.toString());
        if (!response.isSuccess()) {
            LOGGER.warn("Failed to delete DAG file corresponding to {}.", groupId);
            return false;
        }
        // Delete DAG tasks that have been loaded into memory
        AirflowResponse<Object> deleteResponse = serverClient.sendRequest(new DAGDeletor(groupId));
        LOGGER.info("Response to DAG scheduling instance clearing: {}", deleteResponse.toString());
        if (!deleteResponse.isSuccess()) {
            LOGGER.warn("Failed to delete DAG instance corresponding to {}.", groupId);
        }
        return deleteResponse.isSuccess();
    }
Response for processing the start/register/unregister/update/stop requests from {@link AirflowScheduleClient}
inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java