async fn finish_active( active: &mut Option<ActiveWriter>, cancellation: &CancellationToken, ) -> Result<()>