Skip to content
This repository has been archived by the owner on Feb 18, 2024. It is now read-only.

Commit

Permalink
clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
ritchie46 committed Jan 16, 2023
1 parent 11e5369 commit b84e5d7
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 5 deletions.
4 changes: 2 additions & 2 deletions src/io/ipc/compression.rs
Original file line number Diff line number Diff line change
Expand Up @@ -48,13 +48,13 @@ pub fn compress_zstd(input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()> {
}

#[cfg(not(feature = "io_ipc_compression"))]
pub fn compress_lz4(_input_buf: &[u8], _output_buf: &mut Vec<u8>) -> Result<()> {
pub fn compress_lz4(_input_buf: &[u8], _output_buf: &[u8]) -> Result<()> {
use crate::error::Error;
Err(Error::OutOfSpec("The crate was compiled without IPC compression. Use `io_ipc_compression` to write compressed IPC.".to_string()))
}

#[cfg(not(feature = "io_ipc_compression"))]
pub fn compress_zstd(_input_buf: &[u8], _output_buf: &mut Vec<u8>) -> Result<()> {
pub fn compress_zstd(_input_buf: &[u8], _output_buf: &[u8]) -> Result<()> {
use crate::error::Error;
Err(Error::OutOfSpec("The crate was compiled without IPC compression. Use `io_ipc_compression` to write compressed IPC.".to_string()))
}
Expand Down
2 changes: 1 addition & 1 deletion src/io/ipc/write/common_sync.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ pub fn write_message<W: Write>(writer: &mut W, encoded: &EncodedData) -> Result<

// write the flatbuf
if flatbuf_size > 0 {
writer.write_all(&buffer)?;
writer.write_all(buffer)?;
}
// write padding
// aligned to a 8 byte boundary, so maximum is [u8;8]
Expand Down
3 changes: 1 addition & 2 deletions src/temporal_conversions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -295,8 +295,7 @@ fn chrono_tz_utf_to_timestamp_ns<O: Offset>(
timezone: String,
) -> Result<PrimitiveArray<i64>> {
Err(Error::InvalidArgumentError(format!(
"timezone \"{}\" cannot be parsed (feature chrono-tz is not active)",
timezone
"timezone \"{timezone}\" cannot be parsed (feature chrono-tz is not active)",
)))
}

Expand Down

0 comments on commit b84e5d7

Please sign in to comment.