@Override
    public boolean handleRegister(ScheduleInfo scheduleInfo) {
        try {
            LOGGER.info("Registering DAG for {}", scheduleInfo.getInlongGroupId());
            return doRegister(scheduleInfo, true);
        } catch (Exception e) {
            LOGGER.error("The Airflow scheduling task with Group ID {} failed to register.",
                    scheduleInfo.getInlongGroupId(), e);
            throw new AirflowScheduleException(SCHEDULE_TASK_REGISTER_FAILED,
                    String.format("The Airflow scheduling task with Group ID %s failed to register: %s",
                            scheduleInfo.getInlongGroupId(), 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