We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 08793c1 commit 2f5fd66Copy full SHA for 2f5fd66
src/dstack/_internal/server/background/tasks/process_fleets.py
@@ -92,10 +92,14 @@ async def process_fleets():
92
)
93
for fleet_id in fleet_ids:
94
fleet_lockset.add(fleet_id)
95
+ instance_ids = [im.id for im in instance_models]
96
+ for instance_id in instance_ids:
97
+ instance_lockset.add(instance_id)
98
try:
99
await _process_fleets(session=session, fleet_models=fleet_models_to_process)
100
finally:
101
fleet_lockset.difference_update(fleet_ids)
102
+ instance_lockset.difference_update(instance_ids)
103
104
105
async def _process_fleets(session: AsyncSession, fleet_models: List[FleetModel]):
0 commit comments