@Override
    public boolean handleUnregister(String groupId) {
        LOGGER.info("Unregistering Airflow Dag with GroupId {} ", groupId);
        if (scheduledJobSet.contains(groupId)) {
            try {
                if (!completelyDelete(DAGUtil.buildDAGIdByGroupId(groupId))) {
                    return false;
                }
            } catch (Exception e) {
                LOGGER.warn("May not be completely removed {}", groupId, e);
            }
        }
        scheduledJobSet.remove(groupId);
        LOGGER.info("Un-registered airflow schedule info for {}", groupId);
        return true;
    }
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