diff --git a/kubeluigi/__init__.py b/kubeluigi/__init__.py index a50cfab..e71e57f 100644 --- a/kubeluigi/__init__.py +++ b/kubeluigi/__init__.py @@ -102,6 +102,8 @@ def run(self): self.__logger.info("Submitting Kubernetes Job: " + self.uu_name) try: run_and_track_job(self.kubernetes_client, job) + except: + logger.warning("Luigi has failed to submit the job, starting cleaning") finally: clean_job_resources(self.kubernetes_client, job) diff --git a/setup.py b/setup.py index cfebc32..2cd0431 100644 --- a/setup.py +++ b/setup.py @@ -14,7 +14,7 @@ def run_tests(self): sys.exit(pytest.main(self.test_args)) -version = '1.0.4' +version = '1.0.5' setup(name='kubeluigi', version=version,