fix schedule xfail ut case

Signed-off-by: guangli.bao <guangli.bao@daocloud.io>

Author: tukwila

tests/integration/scheduler/test_scheduler.py

@@ -91,7 +91,6 @@ async def resolve(self, request: MockRequest, request_info, request_history):
         yield f"response_for_{request.payload}", request_info
 
 
-@pytest.mark.xfail(reason="old and broken", run=False)
 @pytest.mark.smoke
 @pytest.mark.asyncio
 @async_timeout(10.0)
@@ -122,7 +121,7 @@ async def test_scheduler_run_integration(
     received_updates = defaultdict(list)
     received_responses = []
     last_state = None
-    num_requests = 50
+    num_requests = 100
 
     async for resp, req, info, state in scheduler.run(
         requests=[MockRequest(payload=f"req_{ind}") for ind in range(num_requests)],
@@ -177,4 +176,5 @@ def _request_indices():
         assert statuses in (
             ["queued", "in_progress", "completed"],
             ["queued", "in_progress", "errored"],
+            ["queued", "pending", "in_progress"],
         )

tests/unit/scheduler/test_scheduler.py

@@ -137,7 +137,6 @@ def test_initialization(self, valid_instances):
         assert id(instance1) == id(instance2)
         assert hasattr(instance1, "thread_lock")
 
-    @pytest.mark.xfail(reason="old and broken", run=False)
     @pytest.mark.smoke
     @pytest.mark.asyncio
     @async_timeout(10.0)
@@ -164,6 +163,7 @@ async def test_run_basic_functionality(
             requests=requests,
             backend=backend,
             strategy=strategy,
+            startup_duration=0.1,
             env=env,
             **constraint_args,
         ):
@@ -174,7 +174,6 @@ async def test_run_basic_functionality(
         assert all(isinstance(r[2], RequestInfo) for r in results)
         assert all(isinstance(r[3], SchedulerState) for r in results)
 
-    @pytest.mark.xfail(reason="old and broken", run=False)
     @pytest.mark.smoke
     @pytest.mark.asyncio
     @async_timeout(10.0)
@@ -219,7 +218,6 @@ async def test_run_invalid_parameters(self, valid_instances):
             ):
                 pass
 
-    @pytest.mark.xfail(reason="old and broken", run=False)
     @pytest.mark.smoke
     @pytest.mark.asyncio
     @async_timeout(10.0)