|
3 | 3 | """ |
4 | 4 |
|
5 | 5 | import asyncio |
| 6 | +import logging |
6 | 7 | import tempfile |
7 | 8 | import time |
8 | 9 | from pathlib import Path |
@@ -486,20 +487,28 @@ async def test_benchmark_session_creation_comparison( |
486 | 487 | avg_pooled = sum(pooled_times) / len(pooled_times) |
487 | 488 | avg_non_pooled = sum(non_pooled_times) / len(non_pooled_times) |
488 | 489 |
|
489 | | - print(f"\n{backend_name.title()} Benchmark Results:") |
490 | | - print(f"Average session creation time with pooling: {avg_pooled:.3f}s") |
491 | | - print( |
| 490 | + logging.info(f"\n{backend_name.title()} Benchmark Results:") |
| 491 | + logging.info( |
| 492 | + f"Average session creation time with pooling: {avg_pooled:.3f}s" |
| 493 | + ) |
| 494 | + logging.info( |
492 | 495 | f"Average session creation time without pooling: {avg_non_pooled:.3f}s" |
493 | 496 | ) |
494 | | - print( |
| 497 | + logging.info( |
495 | 498 | f"Performance improvement: {((avg_non_pooled - avg_pooled) / avg_non_pooled * 100):.1f}%" |
496 | 499 | ) |
497 | 500 |
|
498 | 501 | # The second and third pooled sessions should be faster (reusing processes) |
499 | 502 | if len(pooled_times) >= 2: |
500 | | - print(f"First pooled session (new process): {pooled_times[0]:.3f}s") |
501 | | - print(f"Second pooled session (reused process): {pooled_times[1]:.3f}s") |
502 | | - print(f"Third pooled session (reused process): {pooled_times[2]:.3f}s") |
| 503 | + logging.info( |
| 504 | + f"First pooled session (new process): {pooled_times[0]:.3f}s" |
| 505 | + ) |
| 506 | + logging.info( |
| 507 | + f"Second pooled session (reused process): {pooled_times[1]:.3f}s" |
| 508 | + ) |
| 509 | + logging.info( |
| 510 | + f"Third pooled session (reused process): {pooled_times[2]:.3f}s" |
| 511 | + ) |
503 | 512 |
|
504 | 513 | finally: |
505 | 514 | await pool.cleanup() |
@@ -549,10 +558,10 @@ async def test_benchmark_session_reuse_performance(self, lsp_backend, backend_na |
549 | 558 | avg_reuse = sum(reuse_times) / len(reuse_times) |
550 | 559 | avg_fresh = sum(fresh_times) / len(fresh_times) |
551 | 560 |
|
552 | | - print(f"\n{backend_name.title()} Session Reuse Benchmark:") |
553 | | - print(f"Average reused session time: {avg_reuse:.3f}s") |
554 | | - print(f"Average fresh session time: {avg_fresh:.3f}s") |
555 | | - print( |
| 561 | + logging.info(f"\n{backend_name.title()} Session Reuse Benchmark:") |
| 562 | + logging.info(f"Average reused session time: {avg_reuse:.3f}s") |
| 563 | + logging.info(f"Average fresh session time: {avg_fresh:.3f}s") |
| 564 | + logging.info( |
556 | 565 | f"Reuse performance improvement: {((avg_fresh - avg_reuse) / avg_fresh * 100):.1f}%" |
557 | 566 | ) |
558 | 567 |
|
@@ -603,10 +612,12 @@ async def create_fresh_session(session_id: int): |
603 | 612 | fresh_results = await asyncio.gather(*tasks) |
604 | 613 | fresh_time = time.perf_counter() - start_time |
605 | 614 |
|
606 | | - print(f"\n{backend_name.title()} Concurrent Session Creation Benchmark:") |
607 | | - print(f"3 pooled sessions time: {pooled_time:.3f}s") |
608 | | - print(f"3 fresh sessions time: {fresh_time:.3f}s") |
609 | | - print( |
| 615 | + logging.info( |
| 616 | + f"\n{backend_name.title()} Concurrent Session Creation Benchmark:" |
| 617 | + ) |
| 618 | + logging.info(f"3 pooled sessions time: {pooled_time:.3f}s") |
| 619 | + logging.info(f"3 fresh sessions time: {fresh_time:.3f}s") |
| 620 | + logging.info( |
610 | 621 | f"Pooling improvement: {((fresh_time - pooled_time) / fresh_time * 100):.1f}%" |
611 | 622 | ) |
612 | 623 |
|
@@ -661,7 +672,7 @@ async def test_pyrefly_config_options_benchmark(): |
661 | 672 | config_times.append(end_time - start_time) |
662 | 673 |
|
663 | 674 | avg_time = sum(config_times) / len(config_times) |
664 | | - print(f"\nPyrefly Config {config}: Average time {avg_time:.3f}s") |
| 675 | + logging.info(f"\nPyrefly Config {config}: Average time {avg_time:.3f}s") |
665 | 676 |
|
666 | 677 | finally: |
667 | 678 | await pool.cleanup() |
0 commit comments