debug container exec path for function

tapis-project · Oct 24, 2023 · aec2a42 · aec2a42
1 parent f4f987f
commit aec2a42
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 11 deletions.
diff --git a/src/engine/src/core/tasks/executors/Function.py b/src/engine/src/core/tasks/executors/Function.py
@@ -55,19 +55,16 @@ def execute(self):
         job_name = gen_resource_name(prefix="fn")
         # Prepares the file system for the Function task by clone 
         # git repsoitories specified in the request
-        print("Initialize git cache")
         git_cache_service = GitCacheService(cache_dir=self.task.exec_dir)
         try:
             for repo in self.task.git_repositories:
-                print("repo", repo)
                 git_cache_service.add(repo.url, repo.directory, branch=repo.branch)
-                print("cloned successfully")
         except Exception as e:
             return self._task_result(1, errors=[str(e)])
 
         # Set up the container details for the task's specified runtime
         container_details = self._setup_container()
-        print("V1JOB body")
+
         # Job body
         body = client.V1Job(
             metadata=client.V1ObjectMeta(

diff --git a/src/engine/src/helpers/GitCacheService.py b/src/engine/src/helpers/GitCacheService.py
@@ -11,9 +11,7 @@ def add(self, url: str, directory: str, branch=None):
         kwargs = {}
         if branch != None:
             kwargs["branch"] = branch
-        print("BEFORE CLONE")
         git.Repo.clone_from(url, os.path.join(self._cache_dir, directory.lstrip("/")), **kwargs)
-        print("AFTER CLONE")
 
     def repo_exists(self, path):
         return os.path.exists(os.path.join(self._cache_dir, path.lstrip("/")))

diff --git a/src/engine/src/owe_python_sdk/TaskExecutor.py b/src/engine/src/owe_python_sdk/TaskExecutor.py
@@ -103,11 +103,11 @@ def cleanup(self, terminating=False):
         for resource in self._resources:
             # Jobs and Job Pods
             if resource.type == ResourceType.job:
-                self.batch_v1_api.delete_namespaced_job(
-                    name=resource.job.metadata.name,
-                    namespace=KUBERNETES_NAMESPACE,
-                    body=client.V1DeleteOptions(propagation_policy="Background"),
-                )
+                # self.batch_v1_api.delete_namespaced_job(
+                #     name=resource.job.metadata.name,
+                #     namespace=KUBERNETES_NAMESPACE,
+                #     body=client.V1DeleteOptions(propagation_policy="Background"),
+                # )
                 continue
 
             # ConfigMaps