Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
ion-elgreco committed Nov 18, 2023
1 parent e8908f7 commit b196b22
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions python/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -351,14 +351,14 @@ impl RawDeltaTable {
min_commit_interval: Option<u64>,
compression: &str,
) -> PyResult<String> {
let mut compress: Compression = compression.parse().unwrap();
let compress: Compression = compression.parse().unwrap();

let mut cmd = OptimizeBuilder::new(self._table.log_store(), self._table.state.clone())
.with_max_concurrent_tasks(max_concurrent_tasks.unwrap_or_else(num_cpus::get))
.with_writer_properties(
WriterProperties::builder()
.set_compression(compress)
.build()
.build(),
);
if let Some(size) = target_size {
cmd = cmd.with_target_size(size);
Expand Down Expand Up @@ -389,7 +389,7 @@ impl RawDeltaTable {
min_commit_interval: Option<u64>,
compression: &str,
) -> PyResult<String> {
let mut compress: Compression = compression.parse().unwrap();
let compress: Compression = compression.parse().unwrap();

let mut cmd = OptimizeBuilder::new(self._table.log_store(), self._table.state.clone())
.with_max_concurrent_tasks(max_concurrent_tasks.unwrap_or_else(num_cpus::get))
Expand All @@ -398,7 +398,7 @@ impl RawDeltaTable {
.with_writer_properties(
WriterProperties::builder()
.set_compression(compress)
.build()
.build(),
);
if let Some(size) = target_size {
cmd = cmd.with_target_size(size);
Expand Down

0 comments on commit b196b22

Please sign in to comment.