opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-09-24 16:30:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add subpathing to k8s_persistent_volume_claims

Browse Source
This commit is contained in:
Alexandru Mahmoud
2021-04-26 14:33:19 -04:00
committed by almahmoud
parent c0f5487a41
commit 543b51efbe
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/jobs/runners/kubernetes.py
+10 -4
View File
@@ -100,11 +100,17 @@ class KubernetesJobRunner(AsynchronousJobRunner):
volume_claims = dict(volume.split(":") for volume in self.runner_params['k8s_persistent_volume_claims'].split(','))
else:
volume_claims = {}
mountable_volumes = [{'name': claim_name, 'persistentVolumeClaim': {'claimName': claim_name}}
for claim_name in volume_claims if claim_name]
mountable_volumes = list(set([claim_name if "/" not in claim_name else claim_name.split("/")[0] for claim_name in volume_claims]))
mountable_volumes = [{'name': claim_name, 'persistentVolumeClaim': {'claimName': claim_name}} for claim_name in mountable_volumes]
self.runner_params['k8s_mountable_volumes'] = mountable_volumes
volume_mounts = [{'name': claim_name, 'mountPath': mount_path}
for claim_name, mount_path in volume_claims.items() if claim_name]
volume_mounts = [{'name': claim_name, 'mountPath': mount_path} for claim_name, mount_path in volume_claims.items()]
for each in volume_mounts:
vmount = each.get("name")
if "/" in vmount:
name = vmount.split("/")[0]
subpath = vmount.split("/")[1]
each["name"] = name
each["subPath"] = subpath
self.runner_params['k8s_volume_mounts'] = volume_mounts
def queue_job(self, job_wrapper):