@@ -344,73 +344,6 @@ async def setup_farmer_solver_multi_harvester(
344
344
yield harvester_services , farmer_service , block_tools
345
345
346
346
347
- @asynccontextmanager
348
- async def setup_farmer_multi_harvester_with_solver (
349
- block_tools : BlockTools ,
350
- harvester_count : int ,
351
- temp_dir : Path ,
352
- consensus_constants : ConsensusConstants ,
353
- * ,
354
- start_services : bool ,
355
- ) -> AsyncIterator [tuple [list [HarvesterService ], FarmerService , SolverService , BlockTools ]]:
356
- async with AsyncExitStack () as async_exit_stack :
357
- farmer_service = await async_exit_stack .enter_async_context (
358
- setup_farmer (
359
- block_tools ,
360
- temp_dir / "farmer" ,
361
- block_tools .config ["self_hostname" ],
362
- consensus_constants ,
363
- port = uint16 (0 ),
364
- start_service = start_services ,
365
- )
366
- )
367
- if start_services :
368
- farmer_peer = UnresolvedPeerInfo (block_tools .config ["self_hostname" ], farmer_service ._server .get_port ())
369
- else :
370
- farmer_peer = None
371
- harvester_services = [
372
- await async_exit_stack .enter_async_context (
373
- setup_harvester (
374
- block_tools ,
375
- temp_dir / f"harvester_{ i } " ,
376
- farmer_peer ,
377
- consensus_constants ,
378
- start_service = start_services ,
379
- )
380
- )
381
- for i in range (harvester_count )
382
- ]
383
-
384
- # Setup solver with farmer peer - CRITICAL: use same BlockTools root path for SSL CA consistency
385
- solver_service = await async_exit_stack .enter_async_context (
386
- setup_solver (
387
- temp_dir / "solver" , # Use temp_dir like harvester, not block_tools.root_path
388
- block_tools , # Pass BlockTools so SSL CA can be consistent
389
- consensus_constants ,
390
- start_service = start_services ,
391
- )
392
- )
393
-
394
- # Wait for farmer to be fully started before expecting solver connection
395
- if start_services :
396
- import asyncio
397
-
398
- # Wait for farmer to be fully initialized
399
- timeout = 30
400
- for i in range (timeout ):
401
- if farmer_service ._node .started :
402
- print (f"Farmer fully started after { i } seconds" )
403
- break
404
- await asyncio .sleep (1 )
405
- else :
406
- print (f"WARNING: Farmer not started after { timeout } seconds" )
407
-
408
- # Give solver additional time to connect
409
- await asyncio .sleep (3 )
410
-
411
- yield harvester_services , farmer_service , solver_service , block_tools
412
-
413
-
414
347
@asynccontextmanager
415
348
async def setup_full_system (
416
349
consensus_constants : ConsensusConstants ,
0 commit comments