private void switchAllTaskDAG(boolean isPaused) {
        try {
            AirflowResponse<DAGCollection> response = serverClient.sendRequest(
                    new DAGCollectionUpdater(INLONG_OFFLINE_DAG_TASK_PREFIX, isPaused));
            LOGGER.info("Response to {} task DAG : {}", isPaused ? "stop" : "start", response.toString());
            if (!response.isSuccess()) {
                throw new AirflowScheduleException(TASK_DAG_SWITCH_FAILED,
                        String.format("Failed to %s task DAGs.", isPaused ? "stop" : "start"));
            }
            if (!isPaused) {
                List<DAG> dagList = response.getData().getDags();
                if (dagList != null) {
                    dagList.forEach(dag -> scheduledJobSet
                            .add(dag.getDagId().substring(INLONG_OFFLINE_DAG_TASK_PREFIX.length() - 1)));
                }
            }
        } catch (Exception e) {
            LOGGER.error("Failed to {} task DAGs.", isPaused ? "stop" : "start", e);
            throw new AirflowScheduleException(TASK_DAG_SWITCH_FAILED,
                    String.format("Failed to %s task DAGs: %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