pub async fn cleanup_query( storage: &Arc<dyn StorageBackend>, query_id: &str, ) -> Result<()>
Clean up query directory after completion.