Fix(filewatcher): handle removed directories #8800 (#9406)

vercel · Nov 14, 2024 · ab1596c · ab1596c
1 parent 5108eab
commit ab1596c
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 3 deletions.
diff --git a/crates/turborepo-filewatch/src/lib.rs b/crates/turborepo-filewatch/src/lib.rs
@@ -271,8 +271,18 @@ async fn watch_events(
                             if event.kind == EventKind::Create(CreateKind::Folder) {
                                 for new_path in &event.paths {
                                     if let Err(err) = manually_add_recursive_watches(new_path, &mut watcher, Some(&broadcast_sender)) {
-                                        warn!("encountered error watching filesystem {}", err);
-                                        break 'outer;
+                                        match err {
+                                            WatchError::WalkDir(err) => {
+                                                // Likely the path no longer exists
+                                                debug!("encountered error watching filesystem {}", err);
+                                                continue;
+                                            },
+                                            _ => {
+                                                warn!("encountered error watching filesystem {}", err);
+                                                break 'outer;
+                                            }
+
+                                        }
                                     }
                                 }
                             }

diff --git a/crates/turborepo-lib/src/daemon/server.rs b/crates/turborepo-lib/src/daemon/server.rs
@@ -604,7 +604,7 @@ impl proto::turbod_server::Turbod for TurboGrpcServiceInner {
             .package_changes()
             .await;
 
-        let (tx, rx) = mpsc::channel(1024);
+        let (tx, rx) = mpsc::channel(4096);
 
         tx.send(Ok(proto::PackageChangeEvent {
             event: Some(proto::package_change_event::Event::RediscoverPackages(