Struct TaskManager 

pub struct TaskManager { /* private fields */ }

任务生命周期管理器。

Implementations

impl TaskManager

pub fn new(task_repo: Arc<dyn TaskRepository>) -> Self

pub async fn create_tasks( &self, instance_id: &str, node_id: &str, candidates: Vec<String>, ) -> WorkflowResult<Vec<Task>>

为每个候选人生成待办任务。

pub async fn invalidate_by_instance( &self, instance_id: &str, ) -> WorkflowResult<u64>

失效实例所有未完成任务。

pub async fn list_pending_by_candidate( &self, candidate: &str, page: PageRequest, ) -> WorkflowResult<PageResult<Task>>

分页查询候选人待办。

pub async fn get(&self, task_id: &str) -> WorkflowResult<Option<Task>>

获取任务。

pub async fn update(&self, task: &Task) -> WorkflowResult<()>

更新任务。

pub async fn list_by_instance( &self, instance_id: &str, ) -> WorkflowResult<Vec<Task>>

列出实例所有任务。