@Override
    public void start() {
        try {
            // Create authentication information for the Inlong Manger API used by AirFlow
            initConnection();
            // Check if DagCleaner and DagCreator exist and unpause them
            switchOriginalDAG(false);
            // Start all task DAGs and load all DAG ID(Group Id) into the local cache
            switchAllTaskDAG(false);
            LOGGER.info("Airflow initialization succeeded.");
        } catch (Exception e) {
            LOGGER.error("Airflow initialization failed.", e);
        }
    }
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