()
| 428 | |
| 429 | #[test] |
| 430 | fn test_external_task_timeout() { |
| 431 | let task = ExternalTask { |
| 432 | task_id: "test".to_string(), |
| 433 | session_id: "session".to_string(), |
| 434 | lane: SessionLane::Query, |
| 435 | command_type: "read".to_string(), |
| 436 | payload: serde_json::json!({}), |
| 437 | timeout_ms: 100, |
| 438 | created_at: Some(Instant::now()), |
| 439 | }; |
| 440 | |
| 441 | assert!(!task.is_timed_out()); |
| 442 | assert!(task.remaining_ms() <= 100); |
| 443 | } |
| 444 | |
| 445 | #[test] |
| 446 | fn test_session_queue_config_default() { |