We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1108dfc commit cd070e1Copy full SHA for cd070e1
1 file changed
src/chunked/recordbatch_output.rs
@@ -113,13 +113,10 @@ pub(crate) struct DeltaOut {
113
114
impl DeltaOut {
115
async fn deltasetup(schema: FixedSchema, out: PathBuf) -> Result<DeltaTable, DeltaTableError> {
116
- // let table_uri = std::env::var("TABLE_URI").map_err(|e| DeltaTableError::GenericError {
117
- // source: Box::new(e),
118
- // })?;
119
-
+
120
info!("Using the location of: {:?}", out);
121
122
- let table_path = deltalake::Path::parse(out.to_str().unwrap()).unwrap();
+ let table_path =out.to_str().unwrap();
123
124
let maybe_table = deltalake::open_table(&table_path).await;
125
let mut table = match maybe_table {
0 commit comments