something

Author: NSPC911

src/rovr/__main__.py

@@ -340,19 +340,12 @@ def _get_version() -> list[str]:
     if args.force_first_launch:
         return
 
-    import multiprocessing  # noqa: I001
-
-    import rovr.monkey_patches._classes  # noqa: F401
+    import rovr.monkey_patches._classes  # noqa: F401, I001
     import rovr.monkey_patches._platform  # noqa: F401
 
     from rovr.functions.config import set_nested_value
     from rovr.variables.constants import config
 
-    try:
-        multiprocessing.set_start_method("forkserver", force=True)
-    except ValueError:
-        multiprocessing.set_start_method("spawn", force=True)
-
     for feature_path in args.with_features:
         set_nested_value(cast(dict, config), feature_path, True)
 

src/rovr/app.py

@@ -680,13 +680,45 @@ def watch_for_changes_and_update(self) -> None:
                         if new_drives != drives():
                             self.query_one(PinnedSidebar).reload_pins()
                 except Exception as exc:
-                    self.notify(
-                        f"{type(exc).__name__}: {exc}",
-                        title="Drives Watcher",
-                        severity="warning",
-                        markup=False,
-                    )
-                    dump_exc(self, exc)
+                    if isinstance(exc, ValueError) and "fds_to_keep" in str(exc):
+                        # check spawner
+                        match multiprocessing.get_start_method(allow_none=True):
+                            case None:
+                                # try forkserver
+                                try:
+                                    multiprocessing.set_start_method("forkserver")
+                                    self.notify(
+                                        "multiprocessing is now using forkserver"
+                                    )
+                                except ValueError as val_exc:
+                                    if "cannot find context" in str(val_exc):
+                                        multiprocessing.set_start_method("spawn")
+                                        self.notify(
+                                            "multiprocessing is now using spawn"
+                                        )
+                            case "fork":  # theoretically this shouldn't happen
+                                multiprocessing.set_start_method("forkserver")
+                                self.notify("multiprocessing is now using forkserver")
+                            case "forkserver":
+                                multiprocessing.set_start_method("spawn")
+                                self.notify("multiprocessing is now using spawn")
+                            case "spawn":
+                                # nothing else we can do
+                                self.notify(
+                                    f"ValueError: {exc}",
+                                    title="Drives Watcher (Process)",
+                                    severity="error",
+                                    markup=False,
+                                )
+                                dump_exc(self, exc)
+                    else:
+                        self.notify(
+                            f"{type(exc).__name__}: {exc}",
+                            title="Drives Watcher",
+                            severity="warning",
+                            markup=False,
+                        )
+                        dump_exc(self, exc)
             if i_should_shut_down():
                 return