|
17 | 17 | ) |
18 | 18 | from dstack._internal.core.models.placement import PlacementGroup |
19 | 19 | from dstack._internal.core.models.profiles import Profile |
20 | | -from dstack._internal.core.models.resources import Range, ResourcesSpec |
21 | 20 | from dstack._internal.core.models.runs import ( |
22 | 21 | JobStatus, |
23 | 22 | JobTerminationReason, |
@@ -817,17 +816,6 @@ async def test_does_not_assign_job_to_elastic_empty_fleet_without_backend_offers |
817 | 816 | fleet_spec = get_fleet_spec() |
818 | 817 | fleet_spec.configuration.nodes = FleetNodesSpec(min=0, target=0, max=1) |
819 | 818 | await create_fleet(session=session, project=project, spec=fleet_spec, name="fleet") |
820 | | - # Need a second non-empty fleet to have two-stage processing |
821 | | - fleet2 = await create_fleet( |
822 | | - session=session, project=project, spec=fleet_spec, name="fleet2" |
823 | | - ) |
824 | | - await create_instance( |
825 | | - session=session, |
826 | | - project=project, |
827 | | - fleet=fleet2, |
828 | | - instance_num=0, |
829 | | - status=InstanceStatus.BUSY, |
830 | | - ) |
831 | 819 | run = await create_run( |
832 | 820 | session=session, |
833 | 821 | project=project, |
@@ -859,20 +847,6 @@ async def test_assigns_job_to_elastic_empty_fleet_with_backend_offers_if_fleets_ |
859 | 847 | fleet1 = await create_fleet( |
860 | 848 | session=session, project=project, spec=fleet_spec1, name="fleet" |
861 | 849 | ) |
862 | | - # Need a second non-empty fleet to have two-stage processing |
863 | | - fleet_spec2 = get_fleet_spec() |
864 | | - # Empty resources intersection to return no backend offers |
865 | | - fleet_spec2.configuration.resources = ResourcesSpec(cpu=Range(min=0, max=0)) |
866 | | - fleet2 = await create_fleet( |
867 | | - session=session, project=project, spec=fleet_spec2, name="fleet2" |
868 | | - ) |
869 | | - await create_instance( |
870 | | - session=session, |
871 | | - project=project, |
872 | | - fleet=fleet2, |
873 | | - instance_num=0, |
874 | | - status=InstanceStatus.BUSY, |
875 | | - ) |
876 | 850 | run = await create_run( |
877 | 851 | session=session, |
878 | 852 | project=project, |
|
0 commit comments