表结构修改

app/crud/__init__.py

@@ -8,8 +8,6 @@ from app.crud.jm_homework import *
 from app.crud.jm_homework_datasource_relation import *
 from app.crud.jm_job_info import *
 from app.crud.jm_job_node import *
-from app.crud.jm_job_history import *
-from app.crud.jm_job_log import *
 from app.crud.af_task import *
 from app.crud.af_job import *
 from app.crud.af_run import *

app/crud/jm_job_history.py

@@ -1,20 +0,0 @@
-import time
-from typing import List
-from app import models, schemas
-from sqlalchemy.orm import Session
-
-def get_one_job_historys(db: Session, job_id: int):
-    res: List[models.JmJobHistory] = db.query(models.JmJobHistory)\
-            .filter(models.JmJobHistory.job_id == job_id)\
-            .order_by(models.JmJobHistory.trigger_time.desc()).all()
-    return res
-
-def get_historys_by_job_ids(db: Session,job_id_list: List[int]):
-    res: List[models.JmJobHistory] = db.query(models.JmJobHistory)\
-        .filter(models.JmJobHistory.job_id.in_(job_id_list))\
-        .order_by(models.JmJobHistory.trigger_time.desc()).all()
-    return res
-
-def get_jm_job_history_info(db: Session,jm_job_history_id: int):
-    item = db.query(models.JmJobHistory).filter(models.JmJobHistory.id == jm_job_history_id).first()
-    return item

app/crud/jm_job_log.py

@@ -1,14 +0,0 @@
-import time
-from typing import List
-from app import models, schemas
-from sqlalchemy.orm import Session
-
-def get_jm_job_logs(db: Session,job_id_list: List[int]):
-    res: List[models.JmJobLog] = db.query(models.JmJobLog)\
-        .filter(models.JmJobLog.job_id.in_(job_id_list)).all()
-    return res
-
-def get_jm_job_logs_by_history_id(db: Session,jm_job_history_id: int):
-    res: List[models.JmJobLog] = db.query(models.JmJobLog)\
-        .filter(models.JmJobLog.job_history_id == jm_job_history_id).all()
-    return res

app/models/__init__.py

@@ -8,8 +8,6 @@ from app.models.jm_homework_datasource_relation import *
 from app.models.jm_job_info import *
 from app.models.jm_job_node import *
 from app.models.jm_job_edge import *
-from app.models.jm_job_history import *
-from app.models.jm_job_log import *
 from app.models.af_task import *
 from app.models.af_job import *
 from app.models.af_run import *

app/models/jm_job_history.py

@@ -1,19 +0,0 @@
-from sqlalchemy import Boolean, Column, ForeignKey, Integer, String
-
-from app.models.database import BaseModel
-
-
-class JmJobHistory(BaseModel):
-    __tablename__ = "jm_job_history"
-
-    id = Column(Integer, primary_key=True, index=True)
-    # 任务id
-    job_id = Column(Integer, nullable=False)
-    # 调度时间
-    trigger_time = Column(Integer)
-    # 调度结果
-    trigger_result = Column(Integer)
-    # 执行时间
-    executor_time = Column(Integer)
-    # 执行结果
-    executor_result = Column(Integer)

app/models/jm_job_log.py

@@ -1,25 +0,0 @@
-from sqlalchemy import Boolean, Column, ForeignKey, Integer, String
-
-from app.models.database import BaseModel
-
-
-class JmJobLog(BaseModel):
-    __tablename__ = "jm_job_log"
-
-    id = Column(Integer, primary_key=True, index=True)
-    # 任务id
-    job_id = Column(Integer, nullable=False)
-    # 任务历史运行id
-    job_history_id = Column(Integer)
-    # 作业id
-    homework_id = Column(Integer)
-    # 作业名称
-    homework_name = Column(String)
-    # node_uuid
-    node_uuid = Column(String)
-    # node名称
-    node_name = Column(String)
-    # 执行结果
-    executor_result = Column(Integer)
-    # 日志
-    job_log_uri = Column(String)

data/data.sql

@@ -6,74 +6,60 @@ SET FOREIGN_KEY_CHECKS = 0;
 -- Table structure for job_jdbc_datasource
 -- ----------------------------
 DROP TABLE IF EXISTS `job_jdbc_datasource`;
-CREATE TABLE `job_jdbc_datasource`  (
+CREATE TABLE `job_jdbc_datasource` (
   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增主键',
-  `datasource_name` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '数据源名称',
-	`datasource` varchar(45) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '数据源',
-  `datasource_group` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT 'Default' COMMENT '数据源分组',
-	`database_name` varchar(45) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '数据库名',
-  `jdbc_username` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci  COMMENT '用户名',
-  `jdbc_password` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci COMMENT '密码',
-  `jdbc_url` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'jdbc url',
-  `jdbc_driver_class` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'jdbc驱动类',
-  `status` tinyint(1) NOT NULL DEFAULT 1 COMMENT '状态：0删除 1启用 2禁用',
-  `create_by` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '创建人',
-  `create_time` int(20) NULL COMMENT '创建时间',
-  `update_by` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '更新人',
-  `update_time` int(20) NULL COMMENT '更新时间',
-  `comments` varchar(1000) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '备注',
+  `datasource_name` varchar(200) NOT NULL COMMENT '数据源名称',
+  `datasource` varchar(45) NOT NULL COMMENT '数据源',
+  `datasource_group` varchar(200) DEFAULT 'Default' COMMENT '数据源分组',
+  `database_name` varchar(45) NOT NULL COMMENT '数据库名',
+  `jdbc_username` varchar(100) DEFAULT NULL COMMENT '用户名',
+  `jdbc_password` varchar(200) DEFAULT NULL COMMENT '密码',
+  `jdbc_url` varchar(500) NOT NULL COMMENT 'jdbc url',
+  `jdbc_driver_class` varchar(200) DEFAULT NULL COMMENT 'jdbc驱动类',
+  `status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '状态：0删除 1启用 2禁用',
+  `create_by` varchar(20) DEFAULT NULL COMMENT '创建人',
+  `create_time` int(20) DEFAULT NULL COMMENT '创建时间',
+  `update_by` varchar(20) DEFAULT NULL COMMENT '更新人',
+  `update_time` int(20) DEFAULT NULL COMMENT '更新时间',
+  `comments` varchar(1000) DEFAULT NULL COMMENT '备注',
+  `tag` varchar(20) DEFAULT NULL COMMENT '标签: 0开发1测试2开发',
   PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'jdbc数据源配置' ROW_FORMAT = Dynamic;
-
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC COMMENT='jdbc数据源配置';
 
 
 -- ----------------------------
 -- Table structure for job_info
 -- ----------------------------
 DROP TABLE IF EXISTS `job_info`;
-CREATE TABLE `job_info`  (
+CREATE TABLE `job_info` (
   `id` bigint(20) NOT NULL AUTO_INCREMENT,
-  `job_cron` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '任务执行CRON',
-  `job_desc` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
-  `create_time` int(20) NULL COMMENT '创建时间',
-  `update_time` int(20) NULL COMMENT '更新时间',
-  `user_id` int(10) NULL  DEFAULT NULL COMMENT '用户ID',
-  `executor_route_strategy` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '执行器路由策略',
-  `executor_handler` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '执行器任务handler',
-  `executor_param` varchar(512) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '执行器任务参数',
-  `executor_block_strategy` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '阻塞处理策略',
-  `executor_timeout` int(11) NOT NULL DEFAULT 0 COMMENT '任务执行超时时间，单位秒',
-  `executor_fail_retry_count` int(11) NOT NULL DEFAULT 0 COMMENT '失败重试次数',
-  `trigger_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '调度状态：0-停止，1-运行',
-  `trigger_last_time` bigint(13) NULL  COMMENT '上次调度时间',
-  `trigger_next_time` bigint(13) NULL  COMMENT '下次调度时间',
-  `job_json` text CHARACTER SET utf8 COLLATE utf8_general_ci NULL COMMENT 'datax运行脚本',
-  `inc_start_time` int(11) NULL COMMENT '增量初始时间',
-  `last_handle_code` int(11) NULL COMMENT '最近一次执行状态',
+  `cron_select_type` tinyint(4) NOT NULL COMMENT '周期选择类型',
+  `job_cron` varchar(128) NOT NULL COMMENT '任务执行CRON',
+  `job_desc` varchar(255) NOT NULL,
+  `create_time` int(20) DEFAULT NULL COMMENT '创建时间',
+  `update_time` int(20) DEFAULT NULL COMMENT '更新时间',
+  `user_id` varchar(50) NOT NULL COMMENT '用户ID',
+  `executor_route_strategy` varchar(50) DEFAULT NULL COMMENT '执行器路由策略',
+  `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
+  `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
+  `executor_block_strategy` varchar(50) DEFAULT NULL COMMENT '阻塞处理策略',
+  `executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间，单位秒',
+  `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
+  `trigger_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '调度状态：0-停止，1-运行',
+  `trigger_last_time` bigint(13) DEFAULT NULL COMMENT '上次调度时间',
+  `trigger_next_time` bigint(13) DEFAULT NULL COMMENT '下次调度时间',
+  `job_json` text CHARACTER SET utf8 COMMENT 'datax运行脚本',
+  `inc_start_time` int(11) DEFAULT NULL COMMENT '增量初始时间',
+  `last_handle_code` int(11) DEFAULT NULL COMMENT '最近一次执行状态',
+  `delete_status` tinyint(4) NOT NULL COMMENT '数据状态：0-无效，1-有效',
+  `replace_param` varchar(50) DEFAULT NULL COMMENT '增量时间',
+  `partition_info` varchar(50) DEFAULT NULL COMMENT '分区信息',
+  `jvm_param` varchar(50) DEFAULT NULL COMMENT 'jvm参数',
+  `last_time` varchar(50) DEFAULT NULL COMMENT '上次时间字段',
+  `current_time` varchar(50) DEFAULT NULL COMMENT '当前时间字段',
   PRIMARY KEY (`id`) USING BTREE
-) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
-
-
--- ----------------------------
--- Alter Table structure for job_jdbc_datasource
--- ----------------------------
-ALTER TABLE `job_jdbc_datasource`
-ADD COLUMN `tag` varchar(20) NULL COMMENT '标签: 0开发1测试2开发' AFTER `comments`;
-
-
--- ----------------------------
--- Alter Table structure for job_info
--- ----------------------------
-ALTER TABLE `job_info`
-ADD COLUMN `delete_status` tinyint(4) NOT NULL COMMENT '数据状态：0-无效，1-有效' AFTER `last_handle_code`;
-
-
-
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC;
 
-ALTER TABLE `job_info`
-ADD COLUMN `replace_param` varchar(100) NULL COMMENT '增量时间' AFTER `delete_status`,
-ADD COLUMN `partition_info` varchar(100) NULL COMMENT '分区信息' AFTER `replace_param`,
-ADD COLUMN `jvm_param` varchar(100) NULL COMMENT 'jvm参数' AFTER `partition_info`;
 
 
 -- ----------------------------
@@ -120,8 +106,7 @@ CREATE TABLE `data_management` (
   `user_id` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '创建人编号',
   `project_id` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '项目编号',
   PRIMARY KEY (`id`)
-) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='数据管理' ROW_FORMAT=DYNAMIC;
-
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='数据管理';
 
 -- ----------------------------
 -- Table structure for constant
@@ -134,6 +119,20 @@ CREATE TABLE `constant` (
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='常量表';
 
+-- ----------------------------
+-- Records of constant
+-- ----------------------------
+BEGIN;
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (1, '作业类型', 'Java');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (2, '作业类型', 'Python');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (3, '作业类型', 'Dag');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (4, '作业标签', '业务预测');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (5, '作业标签', '作业监测');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (6, '作业标签', '人力系统');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (7, '任务标签', '业务预测');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (8, '任务标签', '任务监测');
+INSERT INTO `constant` (`id`, `type`, `value`) VALUES (9, '任务标签', '人力系统');
+COMMIT;
 
 -- ----------------------------
 -- Table structure for jm_homework
@@ -158,7 +157,6 @@ CREATE TABLE `jm_homework` (
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='作业信息';
 
 
-
 -- ----------------------------
 -- Table structure for jm_homework_datasource_relation
 -- ----------------------------
@@ -167,12 +165,12 @@ CREATE TABLE `jm_homework_datasource_relation` (
   `id` bigint(20) NOT NULL AUTO_INCREMENT,
   `type` varchar(255) COLLATE utf8_unicode_ci NOT NULL COMMENT '类型',
   `datasource_id` bigint(20) NOT NULL COMMENT '数据源ID',
+  `node_uuid` varchar(32) COLLATE utf8_unicode_ci NOT NULL COMMENT '节点uuid',
   `table` varchar(255) COLLATE utf8_unicode_ci NOT NULL COMMENT '数据源对应数据表',
   `homework_id` bigint(20) NOT NULL COMMENT '作业ID',
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='作业与数据源关系表';
 
-
 -- ----------------------------
 -- Table structure for jm_job_info
 -- ----------------------------
@@ -184,7 +182,7 @@ CREATE TABLE `jm_job_info` (
   `tag` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '任务分类',
   `cron_type` tinyint(4) NOT NULL COMMENT '周期类型(1:单次;2:循环)',
   `cron_select_type` tinyint(4) DEFAULT NULL COMMENT '选择周期类型(0:时,1:日,2:周,3:月,4:cron)',
-  `cron_expression` varchar(10) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '周期表达式',
+  `cron_expression` varchar(30) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '周期表达式',
   `api` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT 'api调用',
   `json_str` varchar(10000) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '图形信息',
   `status` tinyint(4) NOT NULL COMMENT '状态(0:停用中;1:启用中)',
@@ -195,6 +193,7 @@ CREATE TABLE `jm_job_info` (
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='定时任务详情';
 
+
 -- ----------------------------
 -- Table structure for jm_job_node
 -- ----------------------------
@@ -208,6 +207,7 @@ CREATE TABLE `jm_job_node` (
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='Job节点表';
 
+
 -- ----------------------------
 -- Table structure for jm_job_edge
 -- ----------------------------
@@ -220,58 +220,11 @@ CREATE TABLE `jm_job_edge` (
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='Job节点关系表';
 
--- ----------------------------
--- Table structure for jm_job_history
--- ----------------------------
-DROP TABLE IF EXISTS `jm_job_history`;
-CREATE TABLE `jm_job_history` (
-  `id` bigint(20) NOT NULL AUTO_INCREMENT,
-  `job_id` bigint(20) NOT NULL COMMENT '任务id',
-  `job_name` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '任务名称',
-  `trigger_time` int(13) DEFAULT NULL COMMENT '调度时间',
-  `trigger_result` tinyint(4) DEFAULT NULL COMMENT '调度结果',
-  `executor_time` int(13) DEFAULT NULL COMMENT '执行时间',
-  `executor_result` tinyint(4) DEFAULT NULL COMMENT '执行结果',
-  PRIMARY KEY (`id`)
-) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='定时任务历史运行情况';
-
-
--- ----------------------------
--- Table structure for jm_job_log
--- ----------------------------
-DROP TABLE IF EXISTS `jm_job_log`;
-CREATE TABLE `jm_job_log` (
-  `id` bigint(20) NOT NULL AUTO_INCREMENT,
-  `job_id` bigint(20) NOT NULL COMMENT '任务id',
-  `job_history_id` bigint(20) DEFAULT NULL COMMENT '任务历史运行id',
-  `homework_id` bigint(20) DEFAULT NULL COMMENT '作业id',
-  `homework_name` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '作业名称',
-  `node_uuid` varchar(32) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '节点uuid',
-  `node_name` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '节点名称',
-  `executor_result` tinyint(4) DEFAULT NULL COMMENT '执行结果',
-  `job_log_uri` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '日志',
-  PRIMARY KEY (`id`)
-) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci COMMENT='定时任务日志';
-
-
--- ----------------------------
--- Alter Table structure for job_info
--- ----------------------------
-ALTER TABLE `job_info`
-ADD COLUMN `cron_select_type` tinyint(4) NOT NULL COMMENT '周期选择类型' AFTER `id`,
-ADD COLUMN `replace_param` varchar(50) NULL COMMENT '增量时间' AFTER `delete_status`,
-ADD COLUMN `partition_info` varchar(50) NULL COMMENT '分区信息' AFTER `replace_param`,
-ADD COLUMN `jvm_param` varchar(50) NULL COMMENT 'jvm参数' AFTER `partition_info`;
-ALTER TABLE `job_info`
-MODIFY COLUMN `user_id` varchar(50) NOT NULL COMMENT '用户ID' AFTER `update_time`;
-ALTER TABLE `job_info`
-ADD COLUMN `last_time` varchar(50) NULL COMMENT '上次时间字段' AFTER `jvm_param`,
-ADD COLUMN `current_time` varchar(50) NULL COMMENT '当前时间字段' AFTER `last_time`;
-
 
 -- ----------------------------
 -- Table structure for relation
 -- ----------------------------
+DROP TABLE IF EXISTS `relation`;
 CREATE TABLE `relation` (
   `id` bigint(20) NOT NULL AUTO_INCREMENT,
   `se_id` bigint(20) DEFAULT NULL COMMENT '服务端id（debug时不存在）',
@@ -279,4 +232,71 @@ CREATE TABLE `relation` (
   `af_id` int(11) NOT NULL COMMENT 'airflow端id',
   `dag_uuid` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT 'dag_uuid(仅在debug时存在)',
   PRIMARY KEY (`id`)
-) ENGINE=InnoDB AUTO_INCREMENT=50 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci;
+
+-- ----------------------------
+-- Table structure for airflow_job
+-- ----------------------------
+DROP TABLE IF EXISTS `airflow_job`;
+CREATE TABLE `airflow_job` (
+  `id` int(11) NOT NULL AUTO_INCREMENT,
+  `name` text COLLATE utf8_unicode_ci,
+  `job_type` int(11) DEFAULT NULL,
+  `tasks` json DEFAULT NULL,
+  `dependence` json DEFAULT NULL,
+  `cron` text COLLATE utf8_unicode_ci NOT NULL,
+  `desc` text COLLATE utf8_unicode_ci NOT NULL,
+  `route_strategy` varchar(32) COLLATE utf8_unicode_ci DEFAULT NULL,
+  `block_strategy` varchar(32) COLLATE utf8_unicode_ci DEFAULT NULL,
+  `executor_timeout` int(11) NOT NULL,
+  `executor_fail_retry_count` int(11) NOT NULL,
+  `trigger_status` int(11) NOT NULL,
+  `trigger_last_time` int(11) DEFAULT NULL,
+  `trigger_next_time` int(11) DEFAULT NULL,
+  `create_time` int(11) DEFAULT NULL,
+  `update_time` int(11) DEFAULT NULL,
+  `user_id` int(11) DEFAULT NULL,
+  `job_mode` int(2) DEFAULT '1',
+  PRIMARY KEY (`id`),
+  KEY `ix_airflow_job_id` (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci;
+
+-- ----------------------------
+-- Table structure for airflow_run
+-- ----------------------------
+DROP TABLE IF EXISTS `airflow_run`;
+CREATE TABLE `airflow_run` (
+  `id` int(11) NOT NULL AUTO_INCREMENT,
+  `start_time` double DEFAULT NULL,
+  `end_time` float DEFAULT NULL,
+  `job_id` int(11) DEFAULT NULL,
+  `af_run_id` varchar(60) COLLATE utf8_unicode_ci DEFAULT NULL,
+  `status` int(11) DEFAULT NULL,
+  `details` json DEFAULT NULL,
+  `run_ts` varchar(60) COLLATE utf8_unicode_ci DEFAULT NULL,
+  PRIMARY KEY (`id`),
+  KEY `ix_airflow_run_id` (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci;
+
+-- ----------------------------
+-- Table structure for airflow_task
+-- ----------------------------
+DROP TABLE IF EXISTS `airflow_task`;
+CREATE TABLE `airflow_task` (
+  `id` int(11) NOT NULL AUTO_INCREMENT,
+  `name` text COLLATE utf8_unicode_ci,
+  `task_type` varchar(16) COLLATE utf8_unicode_ci DEFAULT NULL,
+  `file_urls` json DEFAULT NULL,
+  `script` text COLLATE utf8_unicode_ci,
+  `cmd` text COLLATE utf8_unicode_ci,
+  `cmd_parameters` text COLLATE utf8_unicode_ci,
+  `envs` json DEFAULT NULL,
+  `run_image` text COLLATE utf8_unicode_ci,
+  `create_time` int(11) DEFAULT NULL,
+  `update_time` int(11) DEFAULT NULL,
+  `user_id` int(11) DEFAULT NULL,
+  PRIMARY KEY (`id`),
+  KEY `ix_airflow_task_id` (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8_unicode_ci;
+
+SET FOREIGN_KEY_CHECKS = 1;