Add isolated env

isolated_env.py

@@ -1,34 +1,34 @@
 import os
 import subprocess
 
-# Must have:
-# - giskard
-# - giskard_cicd
-# How to know the other deps?
-def prepare_venv(model_id, deps):
+from io_utils import write_log_to_user_file
+
+
+def prepare_venv(execution_id, deps):
     python_executable = "python"
-    venv_base = f"tmp/venvs/{model_id}"
+    venv_base = f"tmp/venvs/{execution_id}"
 
     pip_executable = os.path.join(venv_base, "bin", "pip")
     # Check pyver
-    subprocess.run([python_executable, "--version"])
+    write_log_to_user_file(execution_id, "Checking Python version")
+    p = subprocess.run([python_executable, "--version"], stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
+    write_log_to_user_file(execution_id, p.stdout.decode())
+    if p.returncode != 0:
+        raise RuntimeError(f"{p.args} ended with {p.returncode}")
     # Create venv
-    subprocess.run([python_executable, "-m", "venv", venv_base, "--clear"])
+    write_log_to_user_file(execution_id, "Creating virtual environment")
+    p = subprocess.run([python_executable, "-m", "venv", venv_base, "--clear"], stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
+    write_log_to_user_file(execution_id, p.stdout.decode())
+    if p.returncode != 0:
+        raise RuntimeError(f"{p.args} ended with {p.returncode}")
     # Output requirements.txt
     requirement_file = os.path.join(venv_base, "requirements.txt")
     with open(requirement_file, "w") as f:
         f.writelines(deps)
     # Install deps
-    subprocess.run([pip_executable, "install", "-r", requirement_file])
-
-
-# Need a file to run model, dataset to get the results back
-# Need to run `giskard_scanner ...` in the environment
-def run_venv(ver, port):
-    python_ver = list(str(v) for v in ver)
-    python_executable = "python" + (".".join(python_ver[:2]))
-    print(f"{python_executable} started: {time.time()}")
-    venv_base = "giskard-home/venvs/" + python_executable + "/123456789"
-    executable = os.path.join(venv_base, "bin", "python")
-    # Run
-    subprocess.Popen([executable, "giskard_venv_boostrap.py", str(port)])
+    write_log_to_user_file(execution_id, "Installing dependencies")
+    p = subprocess.run([pip_executable, "install", "-r", requirement_file], stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
+    write_log_to_user_file(execution_id, p.stdout.decode())
+    if p.returncode != 0:
+        raise RuntimeError(f"{p.args} ended with {p.returncode}")
+    return os.path.join(venv_base, "bin", "giskard_scanner")