rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-05 21:02:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: use better error variant

Browse Source
This commit is contained in:
discord9
2025-04-22 17:30:24 +08:00
parent 0d0dad4ba2
commit 3626a50395
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/flow/src/adapter/flownode_impl.rs
View File

@@ -364,13 +364,13 @@ impl ConsistentCheckTask {
.send((allow_create, allow_drop, tx))
.await
.map_err(|_| {
UnexpectedSnafu {
IllegalCheckTaskStateSnafu {
reason: "Failed to send trigger signal",
}
.build()
})?;
rx.await.map_err(|_| {
UnexpectedSnafu {
IllegalCheckTaskStateSnafu {
reason: "Failed to receive trigger signal",
}
.build()
@@ -380,7 +380,7 @@ impl ConsistentCheckTask {
async fn stop(self) -> Result<(), Error> {
self.shutdown_tx.send(()).await.map_err(|_| {
UnexpectedSnafu {
IllegalCheckTaskStateSnafu {
reason: "Failed to send shutdown signal",
}
.build()