Add keep_alive() call when an error occurs in fetch_next(), to preven…

…t permanent failure when redis restarts

packages/apalis-redis/src/storage.rs

@@ -632,6 +632,7 @@ where
             }
             Err(e) => {
                 warn!("An error occurred during streaming jobs: {e}");
+                self.keep_alive(worker_id).await?;
                 Err(e)
             }
         }