SQ: Bulkheads: Protect RootTask

src/crystal/task.py

@@ -1585,13 +1585,19 @@ def try_get_next_task_unit(self):
 
         return super().try_get_next_task_unit()
 
+    # === Events ===
+
+    @capture_crashes_to(task)
     def child_task_did_complete(self, task: Task) -> None:
         task.dispose()
 
+    @capture_crashes_to(self)
     def did_schedule_all_children(self) -> None:
         # Remove completed children after each scheduling pass
         self.clear_completed_children()
 
+    # === Protected Operations: Finish & Cleanup ===
+
     @overrides
     def clear_children_if_all_complete(self) -> bool:
         raise NotImplementedError(
@@ -1607,13 +1613,17 @@ def fg_task() -> None:
         # NOTE: Must synchronize access to RootTask.children with foreground thread
         fg_call_and_wait(fg_task)
 
+    # === Public Operations ===
+
     def interrupt(self) -> None:
         """
         Stop all descendent tasks, asynchronously,
         by interrupting the scheduler thread.
         """
         self.finish()
 
+    # === Utility ===
+
     def __repr__(self) -> str:
         return f'<RootTask at 0x{id(self):x}>'