()
| 536 | |
| 537 | #[tokio::test] |
| 538 | async fn test_lane_handler_config() { |
| 539 | let (tx, _) = broadcast::channel(100); |
| 540 | let q = SessionLaneQueue::new("s", SessionQueueConfig::default(), tx) |
| 541 | .await |
| 542 | .unwrap(); |
| 543 | assert_eq!( |
| 544 | q.get_lane_handler(SessionLane::Execute).await.mode, |
| 545 | TaskHandlerMode::Internal |
| 546 | ); |
| 547 | q.set_lane_handler( |
| 548 | SessionLane::Execute, |
| 549 | LaneHandlerConfig { |
| 550 | mode: TaskHandlerMode::External, |
| 551 | timeout_ms: 30000, |
| 552 | }, |
| 553 | ) |
| 554 | .await; |
| 555 | let h = q.get_lane_handler(SessionLane::Execute).await; |
| 556 | assert_eq!(h.mode, TaskHandlerMode::External); |
| 557 | assert_eq!(h.timeout_ms, 30000); |
| 558 | } |
| 559 | |
| 560 | #[tokio::test] |
| 561 | async fn test_submit_by_tool() { |
nothing calls this directly
no test coverage detected