|
8 | 8 | - Memory and resource usage under load |
9 | 9 | - Race condition detection |
10 | 10 |
|
11 | | -Tests are marked with @pytest.mark.stress_threading and are designed to be run |
| 11 | +Tests are marked with @pytest.mark.stress and are designed to be run |
12 | 12 | in a dedicated pipeline separate from regular CI tests. |
13 | 13 |
|
14 | 14 | Inspired by: https://github.com/saurabh500/sqlclientrepros/tree/master/python/standalone |
@@ -378,7 +378,7 @@ def stress_conn_str(): |
378 | 378 | # ============================================================================ |
379 | 379 |
|
380 | 380 |
|
381 | | -@pytest.mark.stress_threading |
| 381 | +@pytest.mark.stress |
382 | 382 | @pytest.mark.parametrize( |
383 | 383 | "num_threads,iterations", |
384 | 384 | [ |
@@ -409,7 +409,7 @@ def test_basic_multithreaded_queries(stress_conn_str, num_threads, iterations): |
409 | 409 | ) |
410 | 410 |
|
411 | 411 |
|
412 | | -@pytest.mark.stress_threading |
| 412 | +@pytest.mark.stress |
413 | 413 | @pytest.mark.parametrize( |
414 | 414 | "num_threads,iterations", |
415 | 415 | [ |
@@ -444,7 +444,7 @@ def test_basic_multithreaded_without_pooling(stress_conn_str, num_threads, itera |
444 | 444 | # ============================================================================ |
445 | 445 |
|
446 | 446 |
|
447 | | -@pytest.mark.stress_threading |
| 447 | +@pytest.mark.stress |
448 | 448 | @pytest.mark.parametrize( |
449 | 449 | "num_threads,iterations", |
450 | 450 | [ |
@@ -478,7 +478,7 @@ def test_medium_load_multithreaded(stress_conn_str, num_threads, iterations): |
478 | 478 | ) |
479 | 479 |
|
480 | 480 |
|
481 | | -@pytest.mark.stress_threading |
| 481 | +@pytest.mark.stress |
482 | 482 | def test_50_threads_data_integrity(stress_conn_str): |
483 | 483 | """ |
484 | 484 | Test data integrity with 50 concurrent threads. |
@@ -576,7 +576,7 @@ def worker(thread_id: int): |
576 | 576 | # ============================================================================ |
577 | 577 |
|
578 | 578 |
|
579 | | -@pytest.mark.stress_threading |
| 579 | +@pytest.mark.stress |
580 | 580 | def test_normal_load_cpu_cores(stress_conn_str): |
581 | 581 | """ |
582 | 582 | Test with normal/realistic thread count matching CPU core count. |
@@ -640,7 +640,7 @@ def test_normal_load_cpu_cores(stress_conn_str): |
640 | 640 | # ============================================================================ |
641 | 641 |
|
642 | 642 |
|
643 | | -@pytest.mark.stress_threading |
| 643 | +@pytest.mark.stress |
644 | 644 | @pytest.mark.parametrize( |
645 | 645 | "num_threads,iterations", |
646 | 646 | [ |
@@ -674,7 +674,7 @@ def test_high_load_100_threads(stress_conn_str, num_threads, iterations): |
674 | 674 | print(f"[PASSED] 100 threads test: {result.throughput_qps:.1f} qps") |
675 | 675 |
|
676 | 676 |
|
677 | | -@pytest.mark.stress_threading |
| 677 | +@pytest.mark.stress |
678 | 678 | @pytest.mark.slow |
679 | 679 | def test_extreme_load_2x_cpu_cores(stress_conn_str): |
680 | 680 | """ |
@@ -719,7 +719,7 @@ def test_extreme_load_2x_cpu_cores(stress_conn_str): |
719 | 719 | # ============================================================================ |
720 | 720 |
|
721 | 721 |
|
722 | | -@pytest.mark.stress_threading |
| 722 | +@pytest.mark.stress |
723 | 723 | def test_pool_exhaustion_recovery(stress_conn_str): |
724 | 724 | """ |
725 | 725 | Test that the driver recovers gracefully when connection pool is exhausted. |
@@ -753,7 +753,7 @@ def test_pool_exhaustion_recovery(stress_conn_str): |
753 | 753 | ) |
754 | 754 |
|
755 | 755 |
|
756 | | -@pytest.mark.stress_threading |
| 756 | +@pytest.mark.stress |
757 | 757 | def test_rapid_pool_enable_disable(stress_conn_str): |
758 | 758 | """ |
759 | 759 | Test rapid enabling and disabling of connection pooling. |
@@ -808,7 +808,7 @@ def query_worker(worker_id: int): |
808 | 808 | # ============================================================================ |
809 | 809 |
|
810 | 810 |
|
811 | | -@pytest.mark.stress_threading |
| 811 | +@pytest.mark.stress |
812 | 812 | @pytest.mark.slow |
813 | 813 | def test_sustained_load_5_minutes(stress_conn_str): |
814 | 814 | """ |
@@ -905,7 +905,7 @@ def memory_monitor(): |
905 | 905 | # ============================================================================ |
906 | 906 |
|
907 | 907 |
|
908 | | -@pytest.mark.stress_threading |
| 908 | +@pytest.mark.stress |
909 | 909 | def test_complex_queries_multithreaded(stress_conn_str): |
910 | 910 | """ |
911 | 911 | Test multi-threaded execution with complex queries. |
@@ -942,7 +942,7 @@ def test_complex_queries_multithreaded(stress_conn_str): |
942 | 942 | # ============================================================================ |
943 | 943 |
|
944 | 944 |
|
945 | | -@pytest.mark.stress_threading |
| 945 | +@pytest.mark.stress |
946 | 946 | def test_resource_cleanup_after_stress(stress_conn_str): |
947 | 947 | """ |
948 | 948 | Test that resources are properly cleaned up after stress. |
@@ -985,7 +985,7 @@ def test_resource_cleanup_after_stress(stress_conn_str): |
985 | 985 | # ============================================================================ |
986 | 986 |
|
987 | 987 |
|
988 | | -@pytest.mark.stress_threading |
| 988 | +@pytest.mark.stress |
989 | 989 | @pytest.mark.parametrize( |
990 | 990 | "num_threads,iterations,pooling", |
991 | 991 | [ |
|
0 commit comments