check error

vesoft-inc · Sep 19, 2023 · bfcc89b · bfcc89b
1 parent 92a0739
commit bfcc89b
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 0 deletions.
diff --git a/src/graph/executor/query/AppendVerticesExecutor.cpp b/src/graph/executor/query/AppendVerticesExecutor.cpp
@@ -197,6 +197,7 @@ folly::Future<Status> AppendVerticesExecutor::handleRespMultiJobs(
           }
         }
         auto res = std::move(respVal).value();
+        NG_RETURN_IF_ERROR(res);
         auto &&rows = std::move(res).value();
         std::move(rows.begin(), rows.end(), std::back_inserter(result_.rows));
       }
@@ -242,6 +243,7 @@ folly::Future<Status> AppendVerticesExecutor::handleRespMultiJobs(
             }
           }
           auto res = std::move(respVal).value();
+          NG_RETURN_IF_ERROR(res);
           auto &&rows = std::move(res).value();
           std::move(rows.begin(), rows.end(), std::back_inserter(result_.rows));
         }

diff --git a/src/graph/executor/query/InnerJoinExecutor.cpp b/src/graph/executor/query/InnerJoinExecutor.cpp
@@ -187,6 +187,7 @@ folly::Future<Status> InnerJoinExecutor::probe(const std::vector<Expression*>& p
         }
       }
       auto res = std::move(respVal).value();
+      NG_RETURN_IF_ERROR(res);
       auto&& rows = std::move(res).value();
       result.rows.insert(result.rows.end(),
                          std::make_move_iterator(rows.begin()),
@@ -228,6 +229,7 @@ folly::Future<Status> InnerJoinExecutor::singleKeyProbe(Expression* probeKey, It
         }
       }
       auto res = std::move(respVal).value();
+      NG_RETURN_IF_ERROR(res);
       auto&& rows = std::move(res).value();
       result.rows.insert(result.rows.end(),
                          std::make_move_iterator(rows.begin()),

diff --git a/src/graph/executor/query/LeftJoinExecutor.cpp b/src/graph/executor/query/LeftJoinExecutor.cpp
@@ -164,6 +164,7 @@ folly::Future<Status> LeftJoinExecutor::probe(const std::vector<Expression*>& pr
         }
       }
       auto res = std::move(respVal).value();
+      NG_RETURN_IF_ERROR(res);
       auto&& rows = std::move(res).value();
       result.rows.insert(result.rows.end(),
                          std::make_move_iterator(rows.begin()),
@@ -204,6 +205,7 @@ folly::Future<Status> LeftJoinExecutor::singleKeyProbe(Expression* probeKey, Ite
         }
       }
       auto res = std::move(respVal).value();
+      NG_RETURN_IF_ERROR(res);
       auto&& rows = std::move(res).value();
       result.rows.insert(result.rows.end(),
                          std::make_move_iterator(rows.begin()),

diff --git a/src/graph/executor/query/ProjectExecutor.cpp b/src/graph/executor/query/ProjectExecutor.cpp
@@ -42,6 +42,7 @@ folly::Future<Status> ProjectExecutor::execute() {
           }
         }
         auto res = std::move(respVal).value();
+        NG_RETURN_IF_ERROR(res);
         auto &&rows = std::move(res).value();
         result.rows.insert(result.rows.end(),
                            std::make_move_iterator(rows.begin()),