Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
adriangb authored and ion-elgreco committed May 17, 2024
1 parent 088568f commit 9c816a3
Showing 1 changed file with 7 additions and 15 deletions.
22 changes: 7 additions & 15 deletions python/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -356,8 +356,7 @@ impl RawDeltaTable {
);
};

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(metrics.files_deleted)
Expand Down Expand Up @@ -403,8 +402,7 @@ impl RawDeltaTable {
);
};

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(serde_json::to_string(&metrics).unwrap())
Expand All @@ -419,7 +417,6 @@ impl RawDeltaTable {
writer_properties=None,
custom_metadata=None,
))]

#[allow(clippy::too_many_arguments)]
pub fn compact_optimize(
&mut self,
Expand Down Expand Up @@ -463,8 +460,7 @@ impl RawDeltaTable {
.map_err(PythonError::from)?;
cmd = cmd.with_filters(&converted_filters);

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(serde_json::to_string(&metrics).unwrap())
Expand Down Expand Up @@ -526,8 +522,7 @@ impl RawDeltaTable {
.map_err(PythonError::from)?;
cmd = cmd.with_filters(&converted_filters);

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(serde_json::to_string(&metrics).unwrap())
Expand Down Expand Up @@ -558,8 +553,7 @@ impl RawDeltaTable {
);
};

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(())
Expand Down Expand Up @@ -589,8 +583,7 @@ impl RawDeltaTable {
);
};

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(())
Expand Down Expand Up @@ -1222,8 +1215,7 @@ impl RawDeltaTable {
);
};

rt().block_on(cmd.into_future())
.map_err(PythonError::from)
rt().block_on(cmd.into_future()).map_err(PythonError::from)
})?;
self._table.state = table.state;
Ok(serde_json::to_string(&metrics).unwrap())
Expand Down

0 comments on commit 9c816a3

Please sign in to comment.