US06-06: Automate Phase F End-to-End Acceptance (#82)

tests/e2e/_pipeline_harness.py

@@ -494,6 +494,16 @@ class ArchiveStack:
         self.server.stop()
         self.server.start()
 
+    def restart_worker(self, *, extra_env: dict[str, str] | None = None) -> None:
+        """Replace the worker — a healthy one after a crashed one, by default."""
+        if self.worker is not None and self.worker.poll() is None:
+            self.worker.kill()
+            self.worker.wait(timeout=10)
+        self.worker = start_worker(
+            self.seeded,
+            extra_env={"PHOTO_PIPELINE_ARCHIVE_FREE_SPACE_RESERVE_BYTES": "0", **(extra_env or {})},
+        )
+
     def stop(self) -> None:
         if self.worker is not None:
             self.worker.kill()