diff options
Diffstat (limited to 'tvix/store/src/proto/grpc_blobservice_wrapper.rs')
| -rw-r--r-- | tvix/store/src/proto/grpc_blobservice_wrapper.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/tvix/store/src/proto/grpc_blobservice_wrapper.rs b/tvix/store/src/proto/grpc_blobservice_wrapper.rs index 04097997c2e4..fee97c7d2d0e 100644 --- a/tvix/store/src/proto/grpc_blobservice_wrapper.rs +++ b/tvix/store/src/proto/grpc_blobservice_wrapper.rs @@ -161,10 +161,7 @@ impl super::blob_service_server::BlobService for GRPCBlobServiceWrapper { let data_reader = tokio_util::io::StreamReader::new(data_stream); // prepare a writer, which we'll use in the blocking task below. - let mut writer = self - .blob_service - .open_write() - .map_err(|e| Status::internal(format!("unable to open for write: {}", e)))?; + let mut writer = self.blob_service.open_write(); let result = task::spawn_blocking(move || -> Result<super::PutBlobResponse, Status> { // construct a sync reader to the data |