private void switchOriginalDAG(boolean isPaused) {
        for (String dagId : Arrays.asList(airflowConfig.getDagCleanerId(), airflowConfig.getDagCreatorId())) {
            try {
                AirflowResponse<DAG> response = serverClient.sendRequest(new DAGUpdater(dagId, isPaused));
                LOGGER.info("Response to {} the original DAG : {}", isPaused ? "stop" : "start", response.toString());
                if (!response.isSuccess()) {
                    throw new AirflowScheduleException(TASK_DAG_SWITCH_FAILED,
                            String.format("%s does not exist or failed to %s.", dagId, (isPaused ? "stop" : "start")));
                }
            } catch (Exception e) {
                LOGGER.error("The original DAG {} failed.", isPaused ? "stop" : "start", e);
                throw new AirflowScheduleException(TASK_DAG_SWITCH_FAILED,
                        String.format("The original DAG %s failed: %s.", isPaused ? "stop" : "start", e.getMessage()));
            }
        }
    }
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