Hugging Face's logo

Spaces:
gitdeem
/
dt
Paused

App Files Community
dt / app /models /job.py
gitdeem's picture
gitdeem
Upload 96 files
4e9efe9 verified
Raw History Blame Contribute Delete
2.22 kB
from datetime import datetime
from app import db
class FailedJob(db.Model):
""" 失败任务记录表 """
__tablename__ = 'failed_jobs'
id = db.Column(db.BigInteger, primary_key=True, autoincrement=True)
uuid = db.Column(db.String(255), unique=True) # 任务UUID
connection = db.Column(db.Text, nullable=False) # 连接信息
queue = db.Column(db.Text, nullable=False) # 队列名称
payload = db.Column(db.Text, nullable=False) # 任务负载数据
exception = db.Column(db.Text, nullable=False) # 异常信息
failed_at = db.Column(db.DateTime, default=datetime.utcnow) # 失败时间\
class JobBatch(db.Model):
""" 任务批次记录表 """
__tablename__ = 'job_batches'
id = db.Column(db.String(255), primary_key=True) # 批次ID（UUID）
name = db.Column(db.String(255), nullable=False) # 批次名称
total_jobs = db.Column(db.Integer, nullable=False) # 总任务数
pending_jobs = db.Column(db.Integer, nullable=False) # 待处理数
failed_jobs = db.Column(db.Integer, nullable=False) # 失败任务数
failed_job_ids = db.Column(db.Text, nullable=False) # 失败任务ID列表（JSON）
options = db.Column(db.Text) # 任务选项配置
cancelled_at = db.Column(db.Integer) # 取消时间戳
created_at = db.Column(db.Integer, nullable=False) # 创建时间戳
finished_at = db.Column(db.Integer) # 完成时间戳
class Job(db.Model):
""" 队列任务表 """
__tablename__ = 'jobs'
id = db.Column(db.BigInteger, primary_key=True, autoincrement=True)
queue = db.Column(db.String(255), nullable=False) # 队列名称
payload = db.Column(db.Text, nullable=False) # 任务数据（JSON）
attempts = db.Column(db.SmallInteger, nullable=False) # 尝试次数
reserved_at = db.Column(db.Integer) # 预留时间戳
available_at = db.Column(db.Integer, nullable=False) # 可用时间戳
created_at = db.Column(db.Integer, nullable=False) # 创建时间戳