Skip to content

Commit

Permalink
More linting
Browse files Browse the repository at this point in the history
  • Loading branch information
almahmoud committed Sep 21, 2023
1 parent b2f1de0 commit b9cff90
Showing 1 changed file with 33 additions and 38 deletions.
71 changes: 33 additions & 38 deletions lib/galaxy/jobs/runners/kubernetes.py
Original file line number Diff line number Diff line change
Expand Up @@ -421,48 +421,43 @@ def __get_k8s_service_spec(self, ajs):
return k8s_spec_template

def __get_k8s_ingress_rules_spec(self, ajs, entry_points):
"""This represents the template for the "rules" portion of the Ingress spec."""
"""This represents the template for the "rules" portion of the Ingress spec."""
if "v1beta1" in self.runner_params.get("k8s_ingress_api_version"):
rules_spec = [{
"host": ep["domain"],
"http": {
"paths": [
{
"backend": {
"serviceName": self.__get_k8s_job_name(
self.__produce_k8s_job_prefix(), ajs.job_wrapper
),
"servicePort": int(ep["tool_port"]),
},
"path": ep.get("entry_path", "/"),
"pathType": "Prefix",
}
]
},
}
for ep in entry_points]
"host": ep["domain"],
"http": {
"paths": [{
"backend": {
"serviceName": self.__get_k8s_job_name(
self.__produce_k8s_job_prefix(), ajs.job_wrapper
),
"servicePort": int(ep["tool_port"]),
},
"path": ep.get("entry_path", "/"),
"pathType": "Prefix",
}]
},
} for ep in entry_points]
else:
rules_spec = [{
"host": ep["domain"],
"http": {
"paths": [
{
"backend": {
"service": {
"name": self.__get_k8s_job_name(
self.__produce_k8s_job_prefix(), ajs.job_wrapper
),
"port": { "number": int(ep["tool_port"]) },
}

},
"path": ep.get("entry_path", "/"),
"pathType": "ImplementationSpecific",
}
]
},
}
for ep in entry_points]
"host": ep["domain"],
"http": {
"paths": [{
"backend": {
"service": {
"name": self.__get_k8s_job_name(
self.__produce_k8s_job_prefix(), ajs.job_wrapper
),
"port": {
"number": int(ep["tool_port"])
},
}
},
"path": ep.get("entry_path", "/"),
"pathType": "ImplementationSpecific",
}]
},
} for ep in entry_points]
return rules_spec

def __get_k8s_ingress_spec(self, ajs):
Expand Down

0 comments on commit b9cff90

Please sign in to comment.