taskflow_rs/executor/
config.rs

1use serde::{Deserialize, Serialize};
2use uuid::Uuid;
3
4#[derive(Debug, Clone, Serialize, Deserialize)]
5pub struct ExecutorConfig {
6    pub worker_id: String,
7    pub max_concurrent_tasks: usize,
8    pub task_timeout_seconds: u64,
9    pub heartbeat_interval_seconds: u64,
10}
11
12impl Default for ExecutorConfig {
13    fn default() -> Self {
14        Self {
15            worker_id: format!("worker-{}", Uuid::new_v4()),
16            max_concurrent_tasks: 10,
17            task_timeout_seconds: 300,
18            heartbeat_interval_seconds: 30,
19        }
20    }
21}