Skip to content

Commit 576b9c9

Browse files
committed
Reduces test duplication
1 parent 577347b commit 576b9c9

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

tests/integration/test_job_id_wiring.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -298,7 +298,7 @@ async def test_direct_process_without_job_id_multiple_runs() -> None:
298298
process: LocalProcess = LocalProcess(components=[component], connectors=[], state=state)
299299

300300
job_id_history = set([])
301-
num_runs = 5
301+
num_runs = 3
302302
for _ in range(num_runs):
303303
async with process:
304304
# A job ID should have been auto-generated
@@ -321,11 +321,11 @@ async def test_direct_process_without_job_id_multiple_runs_multiprocessing() ->
321321
# Create a state backend without a specific job ID
322322
state: SqliteStateBackend = SqliteStateBackend()
323323

324-
components: list[MockComponent] = [MockComponent(name=f"mock-component-{i}") for i in range(4)]
324+
components: list[MockComponent] = [MockComponent(name=f"mock-component-{i}") for i in range(3)]
325325
process: RayProcess = RayProcess(components=components, connectors=[], state=state)
326326

327327
job_id_history: set[str] = set([])
328-
num_runs: int = 5
328+
num_runs: int = 3
329329
for _ in range(num_runs):
330330
async with process:
331331
# A job ID should have been auto-generated

0 commit comments

Comments
 (0)