Skip to content

Commit e5f2c0d

Browse files
committed
Drop redundant replicas arg from _update_jobs_to_new_deployment_in_place
1 parent ecb8ba7 commit e5f2c0d

1 file changed

Lines changed: 1 addition & 5 deletions

File tree

  • src/dstack/_internal/server/background/scheduled_tasks

src/dstack/_internal/server/background/scheduled_tasks/runs.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -691,7 +691,6 @@ async def _handle_run_replicas(
691691
session=session,
692692
run_model=run_model,
693693
run_spec=run_spec,
694-
replicas=replica_groups,
695694
)
696695

697696
for group in replica_groups:
@@ -720,7 +719,6 @@ async def _update_jobs_to_new_deployment_in_place(
720719
session: AsyncSession,
721720
run_model: RunModel,
722721
run_spec: RunSpec,
723-
replicas: Optional[List] = None,
724722
) -> None:
725723
"""
726724
Bump deployment_num for jobs that do not require redeployment.
@@ -736,10 +734,8 @@ async def _update_jobs_to_new_deployment_in_place(
736734
if all(j.deployment_num == run_model.deployment_num for j in job_models):
737735
continue
738736

739-
# Determine which group this replica belongs to
740737
replica_group_name = None
741-
742-
if replicas:
738+
if run_spec.configuration.type == "service":
743739
job_spec = get_job_spec(job_models[0])
744740
replica_group_name = job_spec.replica_group
745741

0 commit comments

Comments
 (0)