fix: Cloning persist handle for persist_partitions no longer needed

pull/24376/head
Carol (Nichols || Goulding) 2023-01-12 11:05:25 -05:00
parent 27d58efa18
commit 642bab5db3
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
2 changed files with 2 additions and 2 deletions

View File

@ -343,7 +343,7 @@ where
shutdown_tx,
Arc::clone(&ingest_state),
Arc::clone(&buffer),
persist_handle,
Arc::clone(&persist_handle),
wal,
));

View File

@ -37,7 +37,7 @@ P: PersistQueue + Clone + Sync + 'static,
&self,
_request: Request<proto::PersistRequest>,
) -> Result<Response<proto::PersistResponse>, tonic::Status> {
persist_partitions(self.buffer.partition_iter(), self.persist_handle.clone()).await;
persist_partitions(self.buffer.partition_iter(), &self.persist_handle).await;
Ok(Response::new(proto::PersistResponse {}))
}