fix: fix uncaught error 🥲 (#1929)

fix: fix uncaught error
This commit is contained in:
Weny Xu
2023-07-11 00:41:20 +09:00
committed by GitHub
parent 65f5349767
commit c615fb2a93
2 changed files with 3 additions and 3 deletions

View File

@@ -224,10 +224,10 @@ impl CreateTableProcedure {
}));
}
let _ = join_all(joins)
let _r = join_all(joins)
.await
.into_iter()
.map(|e| e.context(error::JoinSnafu))
.map(|e| e.context(error::JoinSnafu).flatten())
.collect::<Result<Vec<_>>>()?;
self.creator.data.state = CreateTableState::CreateMetadata;

View File

@@ -185,7 +185,7 @@ impl DropTableProcedure {
}));
}
let _ = join_all(joins)
let _r = join_all(joins)
.await
.into_iter()
.map(|e| e.context(error::JoinSnafu).flatten())