diff --git a/svc/pkg/ds/ops/server-create/src/lib.rs b/svc/pkg/ds/ops/server-create/src/lib.rs index c54a2da412..70ced0cbf4 100644 --- a/svc/pkg/ds/ops/server-create/src/lib.rs +++ b/svc/pkg/ds/ops/server-create/src/lib.rs @@ -805,11 +805,6 @@ pub async fn handle( ]), ..TaskGroup::new() }]), - // Disables migrating in the event of a node drain - migrate: Some(Box::new(MigrateStrategy { - max_parallel: Some(0), - ..MigrateStrategy::new() - })), // Disables rescheduling in the event of a node drain reschedule: Some(Box::new(ReschedulePolicy { attempts: Some(0), diff --git a/svc/pkg/faker/ops/job-template/src/lib.rs b/svc/pkg/faker/ops/job-template/src/lib.rs index b85f6facbb..1e9973ccf5 100644 --- a/svc/pkg/faker/ops/job-template/src/lib.rs +++ b/svc/pkg/faker/ops/job-template/src/lib.rs @@ -57,11 +57,6 @@ fn gen_job( tasks: Some(vec![task]), ..TaskGroup::new() }]), - // Disables migrating in the event of a node drain - migrate: Some(Box::new(MigrateStrategy { - max_parallel: Some(0), - ..MigrateStrategy::new() - })), // Disables rescheduling in the event of a node drain reschedule: Some(Box::new(ReschedulePolicy { attempts: Some(0), diff --git a/svc/pkg/job-run/worker/src/workers/create/create_job.rs b/svc/pkg/job-run/worker/src/workers/create/create_job.rs index b6c758460f..14501a05f6 100644 --- a/svc/pkg/job-run/worker/src/workers/create/create_job.rs +++ b/svc/pkg/job-run/worker/src/workers/create/create_job.rs @@ -369,11 +369,6 @@ mod tests { }]), ..TaskGroup::new() }]), - // Disables migrating in the event of a node drain - migrate: Some(Box::new(MigrateStrategy { - max_parallel: Some(0), - ..MigrateStrategy::new() - })), // Disables rescheduling in the event of a node drain reschedule: Some(Box::new(ReschedulePolicy { attempts: Some(0), diff --git a/svc/pkg/mm-config/ops/version-prepare/src/prewarm_ats.rs b/svc/pkg/mm-config/ops/version-prepare/src/prewarm_ats.rs index 138c633811..980c8a6ef8 100644 --- a/svc/pkg/mm-config/ops/version-prepare/src/prewarm_ats.rs +++ b/svc/pkg/mm-config/ops/version-prepare/src/prewarm_ats.rs @@ -178,11 +178,6 @@ fn gen_prewarm_job(artifact_count: usize) -> GlobalResult