File tree Expand file tree Collapse file tree 3 files changed +11
-7
lines changed
tests/test_integration/test_scheduler Expand file tree Collapse file tree 3 files changed +11
-7
lines changed Original file line number Diff line number Diff line change 4949 # This is important, as coverage is exported after receiving SIGTERM
5050 - name : Run Scheduler Tests
5151 run : |
52- docker compose -f ./docker-compose.test.yml --profile worker exec -T worker coverage run -m pytest -vvv -s -m "scheduler "
52+ docker compose -f ./docker-compose.test.yml --profile worker exec -T worker coverage run -m pytest -vvv -s -m "worker and scheduler_integration "
5353
5454 - name : Dump worker logs on failure
5555 if : failure()
File renamed without changes.
Original file line number Diff line number Diff line change 99from syncmaster .settings import Settings
1010from tests .mocks import MockTransfer
1111
12- pytestmark = [pytest .mark .asyncio , pytest .mark .worker ]
12+ pytestmark = [pytest .mark .asyncio , pytest .mark .worker , pytest . mark . scheduler_integration ]
1313
1414
1515async def test_scheduler (
@@ -38,8 +38,12 @@ async def test_scheduler(
3838 assert run is not None
3939 assert run .status in [Status .CREATED , Status .STARTED ]
4040
41- await asyncio .sleep (2 )
42- await session .refresh (run )
43- completed_run = await session .scalar (select (Run ).filter_by (id = run .id ))
44- assert completed_run .status == Status .FINISHED
45- assert completed_run .ended_at is not None
41+ for _ in range (3 ):
42+ await asyncio .sleep (2 )
43+ await session .refresh (run )
44+ run = await session .scalar (select (Run , run .id ))
45+ if run .status == Status .FINISHED :
46+ break
47+
48+ assert run .status == Status .FINISHED
49+ assert run .ended_at is not None
You can’t perform that action at this time.
0 commit comments