Skip to content

Commit 2769b1f

Browse files
address gemini comment
1 parent 8085ae3 commit 2769b1f

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

keras_remote/core/core.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ def run(
2929
project: GCP project (default: from KERAS_REMOTE_PROJECT)
3030
capture_env_vars: List of environment variable names or patterns (ending in *)
3131
to propagate to the remote environment. Defaults to None.
32-
cluster: GKE cluster name (default: from KERAS_REMOTE_GKE_CLUSTER)
32+
cluster: GKE cluster name (default: from KERAS_REMOTE_CLUSTER)
3333
backend: Backend to use ('gke' or 'pathways')
3434
namespace: Kubernetes namespace (default: 'default')
3535
"""
@@ -117,9 +117,7 @@ def _execute_on_gke(
117117
"""Execute function on GKE cluster with GPU/TPU nodes."""
118118
# Get GKE-specific defaults
119119
if not cluster:
120-
cluster = os.environ.get("KERAS_REMOTE_CLUSTER") or os.environ.get(
121-
"KERAS_REMOTE_GKE_CLUSTER"
122-
)
120+
cluster = os.environ.get("KERAS_REMOTE_CLUSTER")
123121
if not namespace:
124122
namespace = os.environ.get("KERAS_REMOTE_GKE_NAMESPACE", "default")
125123

@@ -143,9 +141,7 @@ def _execute_on_pathways(
143141
):
144142
"""Execute function on GKE cluster via ML Pathways."""
145143
if not cluster:
146-
cluster = os.environ.get("KERAS_REMOTE_CLUSTER") or os.environ.get(
147-
"KERAS_REMOTE_GKE_CLUSTER"
148-
)
144+
cluster = os.environ.get("KERAS_REMOTE_CLUSTER")
149145
if not namespace:
150146
namespace = os.environ.get("KERAS_REMOTE_GKE_NAMESPACE", "default")
151147

0 commit comments

Comments
 (0)