Skip to content

Commit

Permalink
Merge pull request #121 from sebastienc/work
Browse files Browse the repository at this point in the history
Some fixes.
  • Loading branch information
sebastienc committed Jun 5, 2018
2 parents 822c356 + 076cc19 commit 23135f8
Show file tree
Hide file tree
Showing 3 changed files with 30 additions and 2 deletions.
28 changes: 28 additions & 0 deletions kubernetes/K8sCronJob.py
Expand Up @@ -89,6 +89,14 @@ def add_image_pull_secrets(self, secrets=None):
self.model.spec.job_template.spec.template.spec.add_image_pull_secrets(secrets)
return self

def add_pod_label(self, k=None, v=None):
labels = self.model.spec.job_template.spec.template.metadata.labels
if labels is None:
labels = {}
labels.update({k: v})
self.model.spec.job_template.spec.template.metadata.labels = labels
return self

def add_volume(self, volume=None):
if not isinstance(volume, K8sVolume):
raise SyntaxError(
Expand All @@ -100,6 +108,15 @@ def add_volume(self, volume=None):
self.model.spec.job_template.spec.template.spec.volumes = volumes
return self

# ------------------------------------------------------------------------------------- del

def del_pod_label(self, k=None):
labels = self.model.spec.job_template.spec.template.metadata.labels
if k in labels:
labels.pop(k)
self.model.spec.job_template.spec.template.metadata.labels = labels
return self

# ------------------------------------------------------------------------------------- schedule

@property
Expand Down Expand Up @@ -277,6 +294,17 @@ def pod(self, p=None):
raise NotImplementedError(
'K8sCronjob: pod is read-only.')

# ------------------------------------------------------------------------------------- pod labels

@property
def pod_labels(self):
return self.model.spec.job_template.spec.template.metadata.labels

@pod_labels.setter
def pod_labels(self, labels=None):
self.model.spec.job_template.spec.template.metadata.labels = labels


# ------------------------------------------------------------------------------------- image pull secrets

@property
Expand Down
2 changes: 1 addition & 1 deletion kubernetes/K8sReplicationController.py
Expand Up @@ -132,7 +132,7 @@ def del_pod_label(self, k=None):
labels = self.model.spec.template.metadata.labels
if k in labels:
labels.pop(k)
self.model.spec.template.metadata.annotations = labels
self.model.spec.template.metadata.labels = labels
return self

def del_pod_node_name(self):
Expand Down
2 changes: 1 addition & 1 deletion version.meta
@@ -1 +1 @@
1.5.6.31
1.5.6.32

0 comments on commit 23135f8

Please sign in to comment.