diff --git a/pydatatask/executor/pod_manager.py b/pydatatask/executor/pod_manager.py index ea6a92b..3114e97 100644 --- a/pydatatask/executor/pod_manager.py +++ b/pydatatask/executor/pod_manager.py @@ -217,6 +217,8 @@ async def launch(self, task: str, job: str, replica: int, manifest): }, } ) + if replica != 0: + manifest["metadata"]["labels"]["preemptable"] = "true" await self.v1.create_namespaced_pod(self.namespace, manifest)