install nodes in conda environments

Author: ad-astra-video

server/api/api.py

@@ -174,7 +174,7 @@ async def models(request):
     '''
     workspace_dir = request.app["workspace"]
     try:
-        nodes = await list_models(workspace_dir)
+        models = await list_models(workspace_dir)
         return web.json_response({"error": None, "models": models})
     except Exception as e:
         return web.json_response({"error": str(e), "models": models}, status=500)

server/api/nodes/nodes.py

@@ -94,12 +94,14 @@ async def install_node(node, workspace_dir):
         # Install requirements if present
         requirements_file = node_path / "requirements.txt"
         if requirements_file.exists():
-            subprocess.run([sys.executable, "-m", "pip", "install", "-r", str(requirements_file)], check=True)
+            subprocess.run(["conda", "run", "-n", "comfystream", "pip", "install", "-r", str(requirements_file)], check=True)
+            subprocess.run(["conda", "run", "-n", "comfyui", "pip", "install", "-r", str(requirements_file)], check=True)
 
         # Install additional dependencies if specified
         if "dependencies" in node:
             for dep in node["dependencies"].split(','):
-                subprocess.run([sys.executable, "-m", "pip", "install", dep.strip()], check=True)
+                subprocess.run(["conda", "run", "-n", "comfystream", "pip", "install", dep.strip()], check=True)
+                subprocess.run(["conda", "run", "-n", "comfyui", "pip", "install", dep.strip()], check=True)
 
     except Exception as e:
         logger.error(f"Error installing {dir_name} {e}")