Function test_worker_pool_error_handling

src/server/worker_pool.rs:322–349

()

    #[tokio::test]
    async fn test_worker_pool_error_handling() {
        let pool = WorkerPool::new(2);

        // Submit a job that will fail
        let job = TestJob {
            id: "failing-job".to_string(),
            duration_ms: 10,
            should_fail: true,
        };

        pool.try_submit(job).await.unwrap().unwrap();

        // Wait for job to complete
        sleep(Duration::from_millis(50)).await;

        // Poll for completed jobs
        let completed = pool.poll_completed().await;
        assert_eq!(completed.len(), 1, "Should have 1 completed job");

        assert!(completed[0].is_err());
        assert!(
            completed[0]
                .as_ref()
                .unwrap_err()
                .message
                .contains("failed as requested")
        );
    }

    #[tokio::test]
    async fn test_worker_pool_try_submit() {