Skip to content

Kubernetes Pod Operator convert container_resources #1821

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tatiana merged 7 commits into from
Jun 23, 2025
+39 −0
Merged

Kubernetes Pod Operator convert container_resources #1821

Changes from 3 commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
96b8677
add convert
johnhoran Jun 20, 2025
022e802
refactor
johnhoran Jun 20, 2025
3092021
Merge branch 'main' into convert_container_resources
tatiana Jun 21, 2025
054e541
add test
johnhoran Jun 23, 2025
fa8a39c
🎨 [pre-commit.ci] Auto format from pre-commit.com hooks
pre-commit-ci[bot] Jun 23, 2025
686d4c1
coverage
johnhoran Jun 23, 2025
9c3a2e8
🎨 [pre-commit.ci] Auto format from pre-commit.com hooks
pre-commit-ci[bot] Jun 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions cosmos/operators/kubernetes.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,10 @@
pass

AbstractDbtBase.__init__(self, **base_kwargs)

container_resources = operator_kwargs.get("container_resources")
if isinstance(container_resources, dict):
Comment thread
tatiana marked this conversation as resolved.
operator_kwargs["container_resources"] = k8s.V1ResourceRequirements(**container_resources)

Check warning on line 104 in cosmos/operators/kubernetes.py

View check run for this annotation

Codecov / codecov/patch

cosmos/operators/kubernetes.py#L104 

Added line #L104 was not covered by tests
KubernetesPodOperator.__init__(self, **operator_kwargs)

def build_env_args(self, env: dict[str, str | bytes | PathLike[Any]]) -> None:
Expand Down