Merge pull request #28 from optimizely/active-deadline-seconds

active deadline seconds
optimizely · Oct 13, 2023 · 7e08710 · 7e08710
2 parents 72b686c + 133bb73
commit 7e08710
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/kubeluigi/__init__.py b/kubeluigi/__init__.py
@@ -39,6 +39,10 @@ def _init_kubernetes(self):
     def restart_policy(self):
         return "Never"
 
+    @property
+    def active_deadline_seconds(self):
+        return None
+
     @property
     def backoff_limit(self):
         """
@@ -92,6 +96,7 @@ def build_job_definition(self) -> V1Job:
             pod_template_spec=pod_template_spec,
             labels=self.labels,
             namespace=self.namespace,
+            active_deadline_seconds=self.active_deadline_seconds
         )
         return job
 

diff --git a/kubeluigi/k8s.py b/kubeluigi/k8s.py
@@ -105,6 +105,7 @@ def job_definition(
     pod_template_spec: V1PodTemplateSpec,
     labels: Dict[str, str],
     namespace: str,
+    active_deadline_seconds=None
 ) -> V1Job:
     """
     returns a job object describing a k8s job.
@@ -115,7 +116,7 @@ def job_definition(
         api_version="batch/v1",
         kind="Job",
         metadata=V1ObjectMeta(name=job_name, labels=labels, namespace=namespace),
-        spec=V1JobSpec(template=pod_template_spec, backoff_limit=backoff_limit),
+        spec=V1JobSpec(template=pod_template_spec, backoff_limit=backoff_limit, active_deadline_seconds=active_deadline_seconds),
     )
 
     return job