Skip to content

Commit 47ecbcd

Browse files
ko3n1gclaude
authored andcommitted
feat: add extra_resource_requests and extra_resource_limits to KubeflowExecutor (#479)
Signed-off-by: oliver könig <okoenig@nvidia.com> Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com> Signed-off-by: NeMo Bot <nemo-bot@nvidia.com>
1 parent 17ae86b commit 47ecbcd

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

nemo_run/core/execution/kubeflow.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,8 @@ class KubeflowExecutor(Executor):
7474
memory_requests: Optional[str] = None
7575
cpu_limits: Optional[str] = None
7676
memory_limits: Optional[str] = None
77+
extra_resource_requests: dict[str, str] = field(default_factory=dict)
78+
extra_resource_limits: dict[str, str] = field(default_factory=dict)
7779
volume_mounts: list[dict[str, Any]] = field(default_factory=list)
7880
volumes: list[dict[str, Any]] = field(default_factory=list)
7981
labels: dict[str, Any] = field(default_factory=dict)
@@ -161,6 +163,8 @@ def _build_resources(self) -> dict[str, Any]:
161163
if self.gpus_per_node is not None:
162164
limits["nvidia.com/gpu"] = str(self.gpus_per_node)
163165
requests["nvidia.com/gpu"] = str(self.gpus_per_node)
166+
requests.update(self.extra_resource_requests)
167+
limits.update(self.extra_resource_limits)
164168
resources: dict[str, Any] = {}
165169
if limits:
166170
resources["limits"] = limits

0 commit comments

Comments
 (0)