datax-admin/app/models/job_info.py

from sqlalchemy import Boolean, Column, ForeignKey, Integer, String

from app.models.database import BaseModel


class JobInfo(BaseModel):
    __tablename__ = "job_info"

    id = Column(Integer, primary_key=True, index=True)
    # 任务执行CRON
    job_cron = Column(String, nullable=False, index=True)
    # 任务描述
    job_desc = Column(String, nullable=False)
    # 创建时间
    create_time = Column(Integer)
    # 更新时间
    update_time = Column(Integer)
    # 创建人
    user_id = Column(Integer)
    # 执行器路由策略
    executor_route_strategy = Column(String)
    # 执行器任务handler
    executor_handler = Column(String)
    # 执行器任务参数
    executor_param = Column(String)
    # 阻塞处理策略
    executor_block_strategy = Column(String)
    # 任务超时时间, 单位分钟
    executor_timeout = Column(Integer, nullable=False)
    # 失败重试次数
    executor_fail_retry_count = Column(Integer, nullable=False)
    # 调度状态: 0-停止 1-运行
    trigger_status = Column(Integer, nullable=False)
    # 上次调度时间
    trigger_last_time = Column(Integer)
    # 下次调度时间
    trigger_next_time = Column(Integer)
    # datax运行脚本
    job_json = Column(String)
    # 增量初始时间
    inc_start_time = Column(Integer)
    # 最近一次执行状态
    last_handle_code = Column(Integer)