@@ -384,7 +384,7 @@ def test_get_default_resource_limits_no_hard_limit_and_lower_than_default(
384
384
resources .ComponentResources ._get_default_resource_limits
385
385
)
386
386
mock_get_serving_res_limits = mocker .patch (
387
- "hsml .client.get_serving_resource_limits" ,
387
+ "hopsworks_common .client.get_serving_resource_limits" ,
388
388
return_value = no_limit_res , # no upper limit
389
389
)
390
390
@@ -408,7 +408,7 @@ def test_get_default_resource_limits_no_hard_limit_and_higher_than_default(
408
408
resources .ComponentResources ._get_default_resource_limits
409
409
)
410
410
mock_get_serving_res_limits = mocker .patch (
411
- "hsml .client.get_serving_resource_limits" ,
411
+ "hopsworks_common .client.get_serving_resource_limits" ,
412
412
return_value = no_limit_res , # no upper limit
413
413
)
414
414
@@ -432,7 +432,7 @@ def test_get_default_resource_limits_with_higher_hard_limit_and_lower_than_defau
432
432
resources .ComponentResources ._get_default_resource_limits
433
433
)
434
434
mock_get_serving_res_limits = mocker .patch (
435
- "hsml .client.get_serving_resource_limits" ,
435
+ "hopsworks_common .client.get_serving_resource_limits" ,
436
436
return_value = hard_limit_res , # upper limit
437
437
)
438
438
@@ -456,7 +456,7 @@ def test_get_default_resource_limits_with_higher_hard_limit_and_higher_than_defa
456
456
resources .ComponentResources ._get_default_resource_limits
457
457
)
458
458
mock_get_serving_res_limits = mocker .patch (
459
- "hsml .client.get_serving_resource_limits" ,
459
+ "hopsworks_common .client.get_serving_resource_limits" ,
460
460
return_value = hard_limit_res , # upper limit
461
461
)
462
462
@@ -481,7 +481,7 @@ def test_get_default_resource_limits_with_lower_hard_limit_and_lower_than_defaul
481
481
resources .ComponentResources ._get_default_resource_limits
482
482
)
483
483
mock_get_serving_res_limits = mocker .patch (
484
- "hsml .client.get_serving_resource_limits" ,
484
+ "hopsworks_common .client.get_serving_resource_limits" ,
485
485
return_value = hard_limit_res , # upper limit
486
486
)
487
487
@@ -506,7 +506,7 @@ def test_get_default_resource_limits_with_lower_hard_limit_and_higher_than_defau
506
506
resources .ComponentResources ._get_default_resource_limits
507
507
)
508
508
mock_get_serving_res_limits = mocker .patch (
509
- "hsml .client.get_serving_resource_limits" ,
509
+ "hopsworks_common .client.get_serving_resource_limits" ,
510
510
return_value = hard_limit_res , # upper limit
511
511
)
512
512
@@ -527,7 +527,7 @@ def test_validate_resources_no_hard_limits_valid_resources(self, mocker):
527
527
requests = resources .Resources (cores = 1 , memory = 1024 , gpus = 0 )
528
528
limits = resources .Resources (cores = 2 , memory = 2048 , gpus = 1 )
529
529
mock_get_serving_res_limits = mocker .patch (
530
- "hsml .client.get_serving_resource_limits" ,
530
+ "hopsworks_common .client.get_serving_resource_limits" ,
531
531
return_value = no_limit_res , # upper limit
532
532
)
533
533
@@ -543,7 +543,7 @@ def test_validate_resources_no_hard_limit_invalid_cores_request(self, mocker):
543
543
requests = resources .Resources (cores = 0 , memory = 1024 , gpus = 0 )
544
544
limits = resources .Resources (cores = 2 , memory = 2048 , gpus = 1 )
545
545
mock_get_serving_res_limits = mocker .patch (
546
- "hsml .client.get_serving_resource_limits" ,
546
+ "hopsworks_common .client.get_serving_resource_limits" ,
547
547
return_value = no_limit_res , # upper limit
548
548
)
549
549
@@ -563,7 +563,7 @@ def test_validate_resources_no_hard_limit_invalid_memory_request(self, mocker):
563
563
requests = resources .Resources (cores = 1 , memory = 0 , gpus = 0 )
564
564
limits = resources .Resources (cores = 2 , memory = 2048 , gpus = 1 )
565
565
mock_get_serving_res_limits = mocker .patch (
566
- "hsml .client.get_serving_resource_limits" ,
566
+ "hopsworks_common .client.get_serving_resource_limits" ,
567
567
return_value = no_limit_res , # upper limit
568
568
)
569
569
@@ -585,7 +585,7 @@ def test_validate_resources_no_hard_limit_invalid_gpus_request(self, mocker):
585
585
) # 0 gpus is accepted
586
586
limits = resources .Resources (cores = 2 , memory = 2048 , gpus = 1 )
587
587
mock_get_serving_res_limits = mocker .patch (
588
- "hsml .client.get_serving_resource_limits" ,
588
+ "hopsworks_common .client.get_serving_resource_limits" ,
589
589
return_value = no_limit_res , # upper limit
590
590
)
591
591
@@ -606,7 +606,7 @@ def test_validate_resources_no_hard_limit_cores_request_out_of_range(self, mocke
606
606
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
607
607
limits = resources .Resources (cores = 1 , memory = 2048 , gpus = 1 )
608
608
mock_get_serving_res_limits = mocker .patch (
609
- "hsml .client.get_serving_resource_limits" ,
609
+ "hopsworks_common .client.get_serving_resource_limits" ,
610
610
return_value = no_limit_res , # upper limit
611
611
)
612
612
@@ -629,7 +629,7 @@ def test_validate_resources_no_hard_limit_invalid_memory_request_out_of_range(
629
629
requests = resources .Resources (cores = 1 , memory = 2048 , gpus = 0 )
630
630
limits = resources .Resources (cores = 2 , memory = 1024 , gpus = 1 )
631
631
mock_get_serving_res_limits = mocker .patch (
632
- "hsml .client.get_serving_resource_limits" ,
632
+ "hopsworks_common .client.get_serving_resource_limits" ,
633
633
return_value = no_limit_res , # upper limit
634
634
)
635
635
@@ -652,7 +652,7 @@ def test_validate_resources_no_hard_limit_invalid_gpus_request_out_of_range(
652
652
requests = resources .Resources (cores = 1 , memory = 1024 , gpus = 2 )
653
653
limits = resources .Resources (cores = 2 , memory = 2048 , gpus = 1 )
654
654
mock_get_serving_res_limits = mocker .patch (
655
- "hsml .client.get_serving_resource_limits" ,
655
+ "hopsworks_common .client.get_serving_resource_limits" ,
656
656
return_value = no_limit_res , # upper limit
657
657
)
658
658
@@ -673,7 +673,7 @@ def test_validate_resources_with_hard_limit_valid_resources(self, mocker):
673
673
requests = resources .Resources (cores = 1 , memory = 1024 , gpus = 0 )
674
674
limits = resources .Resources (cores = 2 , memory = 2048 , gpus = 1 )
675
675
mock_get_serving_res_limits = mocker .patch (
676
- "hsml .client.get_serving_resource_limits" ,
676
+ "hopsworks_common .client.get_serving_resource_limits" ,
677
677
return_value = hard_limit_res , # upper limit
678
678
)
679
679
@@ -689,7 +689,7 @@ def test_validate_resources_with_hard_limit_invalid_cores_limit(self, mocker):
689
689
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
690
690
limits = resources .Resources (cores = 0 , memory = 2048 , gpus = 1 )
691
691
mock_get_serving_res_limits = mocker .patch (
692
- "hsml .client.get_serving_resource_limits" ,
692
+ "hopsworks_common .client.get_serving_resource_limits" ,
693
693
return_value = hard_limit_res , # upper limit
694
694
)
695
695
@@ -709,7 +709,7 @@ def test_validate_resources_with_hard_limit_invalid_memory_limit(self, mocker):
709
709
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
710
710
limits = resources .Resources (cores = 1 , memory = 0 , gpus = 1 )
711
711
mock_get_serving_res_limits = mocker .patch (
712
- "hsml .client.get_serving_resource_limits" ,
712
+ "hopsworks_common .client.get_serving_resource_limits" ,
713
713
return_value = hard_limit_res , # upper limit
714
714
)
715
715
@@ -727,7 +727,7 @@ def test_validate_resources_with_hard_limit_invalid_gpus_limit(self, mocker):
727
727
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
728
728
limits = resources .Resources (cores = 1 , memory = 2048 , gpus = - 1 )
729
729
mock_get_serving_res_limits = mocker .patch (
730
- "hsml .client.get_serving_resource_limits" ,
730
+ "hopsworks_common .client.get_serving_resource_limits" ,
731
731
return_value = hard_limit_res , # upper limit
732
732
)
733
733
@@ -747,7 +747,7 @@ def test_validate_resources_with_hard_limit_invalid_cores_request(self, mocker):
747
747
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
748
748
limits = resources .Resources (cores = 4 , memory = 2048 , gpus = 1 )
749
749
mock_get_serving_res_limits = mocker .patch (
750
- "hsml .client.get_serving_resource_limits" ,
750
+ "hopsworks_common .client.get_serving_resource_limits" ,
751
751
return_value = hard_limit_res , # upper limit
752
752
)
753
753
@@ -768,7 +768,7 @@ def test_validate_resources_with_hard_limit_invalid_memory_request(self, mocker)
768
768
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
769
769
limits = resources .Resources (cores = 3 , memory = 4076 , gpus = 1 )
770
770
mock_get_serving_res_limits = mocker .patch (
771
- "hsml .client.get_serving_resource_limits" ,
771
+ "hopsworks_common .client.get_serving_resource_limits" ,
772
772
return_value = hard_limit_res , # upper limit
773
773
)
774
774
@@ -789,7 +789,7 @@ def test_validate_resources_with_hard_limit_invalid_gpus_request(self, mocker):
789
789
requests = resources .Resources (cores = 2 , memory = 1024 , gpus = 0 )
790
790
limits = resources .Resources (cores = 3 , memory = 2048 , gpus = 4 )
791
791
mock_get_serving_res_limits = mocker .patch (
792
- "hsml .client.get_serving_resource_limits" ,
792
+ "hopsworks_common .client.get_serving_resource_limits" ,
793
793
return_value = hard_limit_res , # upper limit
794
794
)
795
795
@@ -808,7 +808,7 @@ def test_validate_resources_with_hard_limit_invalid_gpus_request(self, mocker):
808
808
809
809
def test_from_response_json_predictor_resources (self , mocker , backend_fixtures ):
810
810
mocker .patch (
811
- "hsml .client.get_serving_resource_limits" ,
811
+ "hopsworks_common .client.get_serving_resource_limits" ,
812
812
return_value = SERVING_RESOURCE_LIMITS ,
813
813
)
814
814
json = backend_fixtures ["resources" ][
@@ -831,7 +831,7 @@ def test_from_response_json_predictor_resources_specific_keys(
831
831
self , mocker , backend_fixtures
832
832
):
833
833
mocker .patch (
834
- "hsml .client.get_serving_resource_limits" ,
834
+ "hopsworks_common .client.get_serving_resource_limits" ,
835
835
return_value = SERVING_RESOURCE_LIMITS ,
836
836
)
837
837
json = backend_fixtures ["resources" ][
@@ -854,7 +854,7 @@ def test_from_response_json_predictor_resources_specific_keys(
854
854
855
855
def test_from_response_json_transformer_resources (self , mocker , backend_fixtures ):
856
856
mocker .patch (
857
- "hsml .client.get_serving_resource_limits" ,
857
+ "hopsworks_common .client.get_serving_resource_limits" ,
858
858
return_value = SERVING_RESOURCE_LIMITS ,
859
859
)
860
860
json = backend_fixtures ["resources" ][
@@ -877,7 +877,7 @@ def test_from_response_json_transformer_resources_specific_keys(
877
877
self , mocker , backend_fixtures
878
878
):
879
879
mocker .patch (
880
- "hsml .client.get_serving_resource_limits" ,
880
+ "hopsworks_common .client.get_serving_resource_limits" ,
881
881
return_value = SERVING_RESOURCE_LIMITS ,
882
882
)
883
883
json = backend_fixtures ["resources" ][
@@ -900,7 +900,7 @@ def test_from_response_json_transformer_resources_default_limits(
900
900
self , mocker , backend_fixtures
901
901
):
902
902
mocker .patch (
903
- "hsml .client.get_serving_resource_limits" ,
903
+ "hopsworks_common .client.get_serving_resource_limits" ,
904
904
return_value = SERVING_RESOURCE_LIMITS ,
905
905
)
906
906
mocker .patch (
0 commit comments