File tree Expand file tree Collapse file tree
src/dstack/_internal/server/background/scheduled_tasks Expand file tree Collapse file tree Original file line number Diff line number Diff line change 55from datetime import datetime , timedelta
66from typing import List , Optional , Union
77
8- from sqlalchemy import func , or_ , select
8+ from sqlalchemy import exists , func , select
99from sqlalchemy .ext .asyncio import AsyncSession
1010from sqlalchemy .orm import (
1111 contains_eager ,
@@ -596,12 +596,11 @@ async def _fetch_fleet_with_master_instance_provisioning_data(
596596 await sqlite_commit (session )
597597 res = await session .execute (
598598 select (FleetModel )
599- .outerjoin (FleetModel .instances )
600599 .where (
601600 FleetModel .id == fleet_model .id ,
602- or_ (
603- InstanceModel .id . is_ ( None ) ,
604- InstanceModel .deleted == True ,
601+ ~ exists (). where (
602+ InstanceModel .fleet_id == fleet_model . id ,
603+ InstanceModel .deleted == False ,
605604 ),
606605 )
607606 .with_for_update (key_share = True , of = FleetModel )
You can’t perform that action at this time.
0 commit comments