use sea_orm::JsonValue; use sea_orm::entity::prelude::*; use serde::{Deserialize, Serialize}; use time::OffsetDateTime; use uuid::Uuid; #[derive( Debug, Clone, Copy, PartialEq, Eq, Default, EnumIter, DeriveActiveEnum, Serialize, Deserialize, )] #[sea_orm(rs_type = "i16", db_type = "SmallInteger")] pub enum TaskStatus { #[default] #[sea_orm(num_value = 0)] Pending, #[sea_orm(num_value = 1)] Running, #[sea_orm(num_value = 2)] Success, #[sea_orm(num_value = 3)] Failed, } #[sea_orm::model] #[derive(Clone, Debug, PartialEq, Eq, DeriveEntityModel)] #[sea_orm(table_name = "system_tasks")] pub struct Model { #[sea_orm(primary_key, auto_increment = false)] pub id: Uuid, pub task_type: String, pub payload: JsonValue, pub status: TaskStatus, pub error: Option, #[sea_orm(default_value = 0)] pub retry_count: i32, pub created_at: OffsetDateTime, pub started_at: Option, pub finished_at: Option, pub next_run_at: Option, pub updated_at: Option, } impl ActiveModelBehavior for ActiveModel {}