Revert incorrect fix

windmill-labs · Jan 3, 2025 · bf9c25c · bf9c25c
1 parent c63d43e
commit bf9c25c
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/backend/windmill-worker/src/python_executor.rs b/backend/windmill-worker/src/python_executor.rs
@@ -35,7 +35,6 @@ use windmill_common::variables::get_secret_value_as_admin;
 use windmill_queue::{append_logs, CanceledBy};
 
 lazy_static::lazy_static! {
-    static ref BUSY_VENV_P: RwLock<HashSet<String>> = RwLock::new(HashSet::new());
 
     static ref PYTHON_PATH: String =
     std::env::var("PYTHON_PATH").unwrap_or_else(|_| "/usr/local/bin/python3".to_string());
@@ -1484,8 +1483,7 @@ pub async fn handle_python_reqs(
             "{py_prefix}/{}",
             req.replace(' ', "").replace('/', "").replace(':', "")
         );
-        if metadata(&venv_p).await.is_ok() && !BUSY_VENV_P.read().await.contains(&venv_p) {
-            BUSY_VENV_P.write().await.insert(venv_p.clone());
+        if metadata(&venv_p).await.is_ok() {
             req_paths.push(venv_p);
             in_cache.push(req.to_string());
         } else {
@@ -1881,9 +1879,8 @@ pub async fn handle_python_reqs(
                 );
             }
         } else {
-            req_paths.push(venv_p.clone());
+            req_paths.push(venv_p);
         }
-        BUSY_VENV_P.write().await.remove(&venv_p);
     }
 
     if has_work {