Test to verify that panicing workloads fail task.

src/errors.rs

@@ -1,4 +1,4 @@
-use std::path::PathBuf;
+use std::{path::PathBuf, fmt::Debug};
 
 use thiserror::Error;
 

src/task/scheduled.rs

@@ -61,7 +61,7 @@ impl<W: Workload + Clone + Send + 'static> ScheduledTask<W> {
             .take()
             .expect("result only called once")
             .join()
-            .unwrap()?;
+            .expect("thread not to panic")?;
         self.state.current_sha = new_sha;
         Ok(())
     }
@@ -113,6 +113,16 @@ mod tests {
         task.await_eligible();
     }
 
+    #[test]
+    #[should_panic]
+    fn scheduled_task_on_panic() {
+        let mut task = ScheduledTask::new(TestWorkload::fail_with(|| panic!("BOOM!")));
+        task.start().unwrap();
+        task.await_finished();
+        assert!(!task.is_running());
+        task.finalize().unwrap();
+    }
+
     #[test]
     fn scheduled_task_on_existing_state() {
         let mut task = ScheduledTask::new(TestWorkload::default());