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 4f3c12f commit f9fb40fCopy full SHA for f9fb40f
axlearn/cloud/gcp/pathways_utils.py
@@ -429,6 +429,11 @@ def _build_pathways_head_job(self):
429
annotations = _LoadBalancer(
430
jobset_name=cfg.name, replicated_job_name=_PATHWAYS_HEAD_REPLICATED_JOB_NAME
431
).metadata
432
+ annotations.update(
433
+ {
434
+ "alpha.jobset.sigs.k8s.io/exclusive-topology": "kubernetes.io/hostname",
435
+ }
436
+ )
437
spec = dict(
438
parallelism=1,
439
completions=1,
@@ -451,6 +456,8 @@ def _build_pathways_worker_container(
451
456
container = self._inner._build_container()
452
457
453
458
worker_container = copy.deepcopy(container)
459
+ worker_container["name"] = "pathways-worker"
460
+
454
461
env_list = worker_container.get("env", [])
455
462
463
pathways_head_address = self._get_pathways_head_address(
0 commit comments