@Override
    public void stop() {
        try {
            switchOriginalDAG(true);
            switchAllTaskDAG(true);
        } catch (Exception e) {
            LOGGER.error("Airflow Schedule Engine shutdown failed: ", e);
            throw new AirflowScheduleException(SCHEDULE_ENGINE_SHUTDOWN_FAILED,
                    String.format("Airflow Schedule Engine shutdown failed: %s", 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