public boolean doRegister(ScheduleInfo scheduleInfo, boolean isFirst) throws Exception {
        if (isFirst && scheduledJobSet.contains(scheduleInfo.getInlongGroupId())) {
            throw new AirflowScheduleException(DAG_DUPLICATE,
                    String.format("Group %s is already registered", scheduleInfo.getInlongGroupId()));
        }
        DAGRunConf.DAGRunConfBuilder confBuilder = DAGRunConf.builder()
                .inlongGroupId(scheduleInfo.getInlongGroupId())
                .startTime(scheduleInfo.getStartTime().getTime())
                .endTime(scheduleInfo.getEndTime().getTime())
                .boundaryType(BoundaryType.TIME.getType())
                .connectionId(airflowConfig.getConnectionId())
                .timezone(DEFAULT_TIMEZONE);
        if (scheduleInfo.getScheduleType() == 1) {
            confBuilder = confBuilder.cronExpr(scheduleInfo.getCrontabExpression());
        } else {
            confBuilder = confBuilder.secondsInterval(DateUtil.intervalToSeconds(scheduleInfo.getScheduleInterval(),
                    scheduleInfo.getScheduleUnit()))
                    .startTime(ScheduleUnit.getScheduleUnit(scheduleInfo.getScheduleUnit()) == ScheduleUnit.ONE_ROUND
                            ? scheduleInfo.getEndTime().getTime()
                            : scheduleInfo.getStartTime().getTime());
        }
        DAGRunConf dagRunConf = confBuilder.build();
        AirflowResponse<DAGRun> response = serverClient.sendRequest(
                new DAGRunsTrigger(airflowConfig.getDagCreatorId(), ImmutableMap.of("conf", dagRunConf)));
        LOGGER.info("DAG {} response: {}", isFirst ? "registration" : "update", response.toString());
        if (response.isSuccess()) {
            scheduledJobSet.add(scheduleInfo.getInlongGroupId());
        }
        return response.isSuccess();
    }
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