use executor.spawn from within the worker to start the storage heartb…

…eat tasks as shutdown signals are not propagating through Graceful futures within a Graceful future (#195)

Co-authored-by: kdesjard <[email protected]>

packages/apalis-core/src/worker/ready.rs

@@ -70,7 +70,7 @@ where
         let (send, mut recv) = futures::channel::mpsc::channel::<()>(1);
         // Setup any heartbeats by the worker
         for mut beat in self.beats {
-            ctx.spawn(async move {
+            ctx.executor.spawn(async move {
                 #[cfg(feature = "async-std-comp")]
                 #[allow(unused_variables)]
                 let sleeper = crate::utils::timer::AsyncStdTimer;