Skip to content

Commit

Permalink
move From<PolarsError> for CliError to clitypes.rs from joinp.rs
Browse files Browse the repository at this point in the history
  • Loading branch information
jqnatividad committed Mar 12, 2024
1 parent d7721be commit f58eaf3
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
7 changes: 7 additions & 0 deletions src/clitypes.rs
Original file line number Diff line number Diff line change
Expand Up @@ -225,3 +225,10 @@ impl From<reqwest::Error> for CliError {
CliError::Network(err.to_string())
}
}

#[cfg(feature = "polars")]
impl From<polars::error::PolarsError> for CliError {
fn from(err: polars::error::PolarsError) -> CliError {
CliError::Other(format!("Polars error: {err:?}"))
}
}
8 changes: 1 addition & 7 deletions src/cmd/joinp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ use polars::{
use serde::Deserialize;
use tempfile::tempdir;

use crate::{cmd::sqlp::compress_output_if_needed, config::Delimiter, util, CliError, CliResult};
use crate::{cmd::sqlp::compress_output_if_needed, config::Delimiter, util, CliResult};

#[derive(Deserialize)]
struct Args {
Expand Down Expand Up @@ -225,12 +225,6 @@ struct Args {
flag_quiet: bool,
}

impl From<polars::error::PolarsError> for CliError {
fn from(err: polars::error::PolarsError) -> CliError {
CliError::Other(format!("Polars error: {err:?}"))
}
}

pub fn run(argv: &[&str]) -> CliResult<()> {
let mut args: Args = util::get_args(USAGE, argv)?;

Expand Down

0 comments on commit f58eaf3

Please sign in to comment.